kvs

package module

v2.2.0 Latest Latest Go to latest Published: Aug 14, 2023 License: BSD-3-Clause-Clear Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func CompareBytesToAny(a []byte, i interface{}) bool

func Get(db KVDB, e *Entry) error

func LoadEntries(s interface{}, entries []Entry) error

func LoadEntry(s interface{}, entry Entry) error

func LoadID(s any, rowID uint32) error

func Store(db KVDB, e Entry) error

type Entry struct {
	TableName  string
	ColumnName string
	OwnerUUID  UUID
	RowID      uint32
	Data       []byte
	Meta       byte
}

func ConvertToBlankEntries(tableName string, ownerID UUID, rowID uint32, x any) []Entry

func ConvertToEntries(tableName string, ownerID UUID, rowID uint32, x any) []Entry

func (e Entry) Key() []byte

func (e Entry) PrefixKey() []byte

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

func NewKVDB(db *badger.DB) (KVDB, error)

func NewMemKVDB() (KVDB, error)

func (db KVDB) Close() error

func (db KVDB) DumpTo(w io.Writer) error

func (db KVDB) DumpToStdout() error

func (db KVDB) GetSeq(key []byte, bandwidth uint64) (*badger.Sequence, error)

func (db KVDB) Update(f func(txn *badger.Txn) error) error

func (db KVDB) View(f func(txn *badger.Txn) error) error

type RootOwner struct{}

func (o RootOwner) String() string

type UUID interface {
	String() string
}