store

type Metrics struct {
	Read  ReadMetrics
	Write WriteMetrics
}

type Option func(s *Store) error

type ReadMetrics struct {
	ReaderCalls    int // Number of Store.Reader() calls
	TotalBytesRead int
	TotalTime      time.Duration
}

type Reader interface {
	io.ReadCloser
	Version() Version
}

type ReaderOption func(*ReaderOptions) error

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

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

type Version struct {
	// Time uniquely identifies version
	Time time.Time
	Size int64
}

type WriteMetrics struct {
	WriterCalls       int // Number of Store.Writer() calls
	Successful        int // Number of successful writes (when writer was closed without aborting)
	Aborted           int // Number of aborted writes (when Writer.AbortAndClose was called)
	TotalBytesWritten int
	TotalTime         time.Duration
}

type Writer interface {
	io.Writer
	// Close must be called to make version readable
	Close() error
	Version() Version
	// AbortAndClose aborts writing version. Version will not be available to read.
	AbortAndClose()
}

type WriterOption func(*WriterOptions) error

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