kiroku

type BatchFn func(*Transaction)

type Block []byte

type Consumer struct {
	// contains filtered or unexported fields
}

type File interface {
	io.Seeker
	io.Reader
	io.ReaderAt
}

type Filename struct {
	Name      string
	CreatedAt int64
	Filetype  Type
}

type IOSource struct {
	// contains filtered or unexported fields
}

type Info struct {
	Key          string `json:"key"`
	Hash         string `json:"hash"`
	Size         int64  `json:"size"`
	LastModified int64  `json:"lastModified"`
}

type Ledger interface {
	Meta() (m Meta, err error)
	Transaction(fn func(*Transaction) error) (err error)
	Snapshot(fn func(*Snapshot) error) (err error)
	Filename() (filename string, err error)
	Close() (err error)
}

type Meta struct {
	// LastProcessedTimestamp is the last processed timestamp
	LastProcessedTimestamp int64 `json:"lastProcessedTimestamp"`
	LastProcessedType      Type  `json:"lastProcessedType"`

	LastDownloadedTimestamp int64 `json:"lastDownloadedTimestamp"`
	LastDownloadedType      Type  `json:"lastDownloadedType"`
}

type NOOP struct {
}

type Options struct {
	Dir       string `toml:"dir" json:"dir"`
	Name      string `toml:"name" json:"name"`
	Namespace string `toml:"namespace" json:"namespace"`

	OnLog    func(message string)
	OnError  func(err error)
	OnResume func()

	Debugging bool `toml:"debugging" json:"debugging"`

	AvoidExportOnClose  bool `toml:"avoid_export_on_close" json:"avoidExportOnClose"`
	AvoidProcessOnClose bool `toml:"avoid_merge_on_close" json:"avoidMergeOnClose"`

	ConsumerFileLimit        int64 `toml:"consumer_file_limit" json:"consumerFileLimit"`
	ConsumerConcurrencyCount int   `toml:"consumer_concurrency_count" json:"consumerConcurrencyCount"`
	ConsumerGetNextListSize  int64 `toml:"consumer_get_next_list_size" json:"consumerGetNextListSize"`

	// BatchDuration represents the amount of time to keep a transaction open for a
	// Batch operation
	BatchDuration time.Duration `toml:"batch_duration" json:"batchDuration"`

	// EndOfResultsDelay represents the amount of time to wait before pulling "Next" after
	// receiving empty results (Default is 10 seconds).
	EndOfResultsDelay time.Duration `toml:"end_of_results_delay" json:"endOfResultsDelay"`

	// ErrorDelay represents the amount of time to wait before pulling "Next" after
	// receiving an error
	ErrorDelay time.Duration `toml:"error_delay" json:"errorDelay"`

	// RangeStart will determine the moment in time from which syncs will begin
	RangeStart time.Time `toml:"range_start" json:"rangeStart"`
	// RangeEnd will determine the moment in time from which syncs will end
	// Note: This feature is slated to be implemented within the following
	// release. As of now, this will act as a field placeholder
	RangeEnd time.Time `toml:"range_end" json:"rangeEnd"`
}

type Processor func(*Reader) error

type Producer struct {
	// contains filtered or unexported fields
}

type Reader struct {
	// contains filtered or unexported fields
}

type Snapshot struct {
	// contains filtered or unexported fields
}

type Source interface {
	Export(ctx context.Context, prefix, filename string, r io.Reader) (newFilename string, err error)
	Import(ctx context.Context, prefix, filename string, w io.Writer) error
	Get(ctx context.Context, prefix, filename string, fn func(io.Reader) error) error
	GetNext(ctx context.Context, prefix, lastFilename string) (filename string, err error)
	GetNextList(ctx context.Context, prefix, lastFilename string, maxkeys int64) (nextKeys []string, err error)
	GetInfo(ctx context.Context, prefix, filename string) (info Info, err error)
}

type Transaction struct {
	// contains filtered or unexported fields
}

type TransactionFn func(*Transaction) error

type Type uint8

type UpdateFunc func(Type, *Reader) error

type Writer struct {
	// contains filtered or unexported fields
}