buffered

type BufferedKVStore interface {
	kv.KVStore

	// the uncommitted mutations
	Mutations() MutationSequence
	ClearMutations()
	Clone() BufferedKVStore

	// only for testing!
	DangerouslyDumpToDict() dict.Dict
	// only for testing!
	DangerouslyDumpToString() string
}

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

type Mutation interface {
	Read(io.Reader) error
	Write(io.Writer) error

	String() string

	ApplyTo(w kv.KVStoreWriter)

	// Key returns the key that is mutated
	Key() kv.Key
	// Value returns the value after the mutation (nil if deleted)
	Value() []byte
	// contains filtered or unexported methods
}

type MutationSequence interface {
	Read(io.Reader) error
	Write(io.Writer) error

	String() string

	Clone() MutationSequence

	Len() int

	// Iterate over all mutations in order, even ones affecting the same key repeatedly
	Iterate(func(mut Mutation) bool)
	// Iterate over the latest mutation recorded for each key
	IterateLatest(func(key kv.Key, mut Mutation) bool)
	// Iterate over the latest value recorded for each non-deleted key
	IterateValues(prefix kv.Key, f func(key kv.Key, value []byte) bool) (map[kv.Key]bool, bool)

	Latest(key kv.Key) Mutation

	Add(mut Mutation)

	ApplyTo(w kv.KVStoreWriter)
}