storage

type Entry struct {
	Key   []byte
	Value []byte
}

type IterOptions struct {
	Reverse     bool
	FetchValues bool
	FillCache   bool
}

type Iterator interface {
	Rewind()
	Seek([]byte)
	Valid() bool
	ValidForPrefix(prefix []byte) bool
	Item() *Entry
	Next()
	Close() error
}

type MessageIterator interface {
	Rewind() *sgproto.Message
	Seek(sandflake.ID) *sgproto.Message
	Valid() bool
	Next() *sgproto.Message
	Close() error
}

type Storage interface {
	Get(key []byte) ([]byte, error)
	Put(key, val []byte) error
	BatchPut(entries []*Entry) error
	Iter(*IterOptions) Iterator
	Close() error
	LastKeyForPrefix(prefix []byte) []byte
	LastKVForPrefix(prefix, suffix []byte) []byte
	ForEach(fn func(msg *sgproto.Message) error) error
	ForRange(min, max sandflake.ID, fn func(msg *sgproto.Message) error) error
	ForEachWALEntry(min []byte, fn func(msg *sgproto.Message) error) error
}