commitlog

type CommitLog interface {
	io.Closer
	// WriteEntry appends a binary payload to the commitlog.
	WriteEntry(ts uint64, value []byte) (uint64, error)
	// Delete closes then deletes the commitlog from disk.
	Delete() error
	// Reader returns a seekable reader
	Reader() Cursor
	// Offset returns the offset of the next record the be written.
	Offset() uint64
	Datadir() string
	//LookupTimestamp returns the seekable offset of the first record writen after the provided timestamp.
	LookupTimestamp(ts uint64) uint64
	//Latest returns the timestamp of the most recent record
	Latest() uint64
	GetStatistics() Statistics
	TruncateAfter(offset uint64) error
	// TruncateBefore delete segments before the one containing the provided offset
	TruncateBefore(offset uint64) error
}

type Cursor interface {
	io.ReadSeeker
}

type Decoder interface {
	Decode() (Entry, error)
}

type Entry interface {
	Size() uint64
	Offset() uint64
	Timestamp() uint64
	Checksum() []byte
	Payload() []byte
	IsValid() bool
}

type Index interface {
	Sync() error
	FilePath() string
	Name() string
	io.Closer
	// contains filtered or unexported methods
}

type Segment interface {
	Name() string
	BaseOffset() uint64
	CurrentOffset() uint64
	Size() uint64
	Delete() error
	WriteEntry(ts uint64, buf []byte) (uint64, error)
	Earliest() uint64
	Latest() uint64
	LookupTimestamp(ts uint64) uint64
	LookupPosition(offset uint64) (int64, error)
	TruncateAfter(offset uint64) error
	io.ReaderAt
	io.Closer
}

type Statistics struct {
	SegmentCount  uint64
	CurrentOffset uint64
	StoredBytes   uint64
}