elldb

type DB interface {

	// Open opens the database
	Open(namespace string) error

	// Close closes the database
	Close() error

	// Put writes many objects to the database in one atomic request
	Put([]*KVObject) error

	// GetByPrefix returns valyes matching a prefix
	GetByPrefix([]byte) (result []*KVObject)

	// GetFirstOrLast returns one value matching a prefix.
	// Set first to return the first value we find or false if the last.
	GetFirstOrLast(prefix []byte, first bool) *KVObject

	// Iterate finds a set of objects by prefix and passes them ro iterFunc
	// for further processing. If iterFunc returns true, the iterator is immediately released.
	// If first is set to true, it begins from the first item, otherwise, the last
	Iterate(prefix []byte, first bool, iterFunc func(kv *KVObject) bool) error

	// DeleteByPrefix deletes one or many records by prefix
	DeleteByPrefix([]byte) error

	// Truncate removes all items
	Truncate() error

	// NewTx creates a transaction
	NewTx() (Tx, error)
}

type KVObject struct {
	Key    []byte `json:"key"`
	Value  []byte `json:"value"`
	Prefix []byte `json:"prefix"`
}

type LevelDB struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Transaction struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Tx interface {

	// Put puts one or more objects
	Put([]*KVObject) error

	// GetByPrefix gets objects by prefix
	GetByPrefix([]byte) (result []*KVObject)

	// Iterate finds a set of objects by prefix and passes them to iterFunc
	// for further processing. If iterFunc returns true, the iterator is immediately released.
	// If first is set to true, it begins from the first item, otherwise, the last
	Iterate(prefix []byte, first bool, iterFunc func(kv *KVObject) bool)

	// DeleteByPrefix deletes one or many records by prefix
	DeleteByPrefix([]byte) error

	// Commit commits the transaction
	Commit() error

	// Rollback roles back the transaction
	Rollback()

	// Discard the transaction. Do not call
	// functions in the transaction after this.
	Discard()
}

type TxCreator interface {
	// NewTx creates a transaction
	NewTx() (Tx, error)
}