kv

package
v0.0.0-...-8526a12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2024 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBolt

func NewBolt(fpath string) (*boltKV, error)

Types

type Iterator

type Iterator interface {
	Valid() bool
	Next() error
	Entry() (key, value []byte, err error)
	Close()
}

type KV

type KV interface {
	Get(key []byte) ([]byte, error)
	Set(key []byte, value []byte) error
	Delete(key []byte) error
	Exist(key []byte) bool
	Iter(key []byte) (Iterator, error)
	NewKvTxn() (KvTxn, error)
}

func NewKV

func NewKV(prefix string, kvdb Kvdb) KV

type KvInstance

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

func (*KvInstance) Delete

func (k *KvInstance) Delete(key []byte) error

func (*KvInstance) Exist

func (k *KvInstance) Exist(key []byte) bool

func (*KvInstance) Get

func (k *KvInstance) Get(key []byte) ([]byte, error)

func (*KvInstance) Iter

func (k *KvInstance) Iter(key []byte) (Iterator, error)

func (*KvInstance) NewKvTxn

func (k *KvInstance) NewKvTxn() (KvTxn, error)

func (*KvInstance) Set

func (k *KvInstance) Set(key []byte, value []byte) error

type KvTxn

type KvTxn interface {
	Get(key []byte) ([]byte, error)
	Set(key, value []byte) error
	Delete(key []byte) error
	Commit() error
	Rollback() error
}

type Kvdb

type Kvdb interface {
	storage.StorageType
	New(prefix string) KV
	Get(prefix string, key []byte) ([]byte, error)
	Set(prefix string, key []byte, value []byte) error
	Delete(prefix string, key []byte) error
	Exist(prefix string, key []byte) bool
	Iter(prefix string, key []byte) (Iterator, error)
	NewKvTxn(prefix string) (KvTxn, error)
}

func NewKvdb

func NewKvdb(cfg *KVconf) (Kvdb, error)

func NewPebble

func NewPebble(fpath string) (Kvdb, error)

type Pebble

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

func (*Pebble) Delete

func (p *Pebble) Delete(prefix string, key []byte) error

func (*Pebble) Exist

func (p *Pebble) Exist(prefix string, key []byte) bool

func (*Pebble) Get

func (p *Pebble) Get(prefix string, key []byte) ([]byte, error)

func (*Pebble) Iter

func (p *Pebble) Iter(prefix string, key []byte) (Iterator, error)

func (*Pebble) Kind

func (p *Pebble) Kind() storage.StoreKind

func (*Pebble) New

func (p *Pebble) New(prefix string) KV

func (*Pebble) NewKvTxn

func (p *Pebble) NewKvTxn(prefix string) (KvTxn, error)

func (*Pebble) Set

func (p *Pebble) Set(prefix string, key []byte, value []byte) error

func (*Pebble) Type

func (p *Pebble) Type() storage.StoreType

type PebbleIter

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

func (*PebbleIter) Close

func (p *PebbleIter) Close()

func (*PebbleIter) Entry

func (p *PebbleIter) Entry() (key, value []byte, err error)

func (*PebbleIter) Next

func (p *PebbleIter) Next() (err error)

func (*PebbleIter) Valid

func (p *PebbleIter) Valid() bool

type PebbleTxn

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

func (*PebbleTxn) Commit

func (p *PebbleTxn) Commit() error

func (*PebbleTxn) Delete

func (p *PebbleTxn) Delete(key []byte) error

func (*PebbleTxn) Get

func (p *PebbleTxn) Get(key []byte) ([]byte, error)

func (*PebbleTxn) Rollback

func (p *PebbleTxn) Rollback() error

func (*PebbleTxn) Set

func (p *PebbleTxn) Set(key, value []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL