kv

Documentation

Index

• Constants
• type Config
• type KVTxn
  • func (kv *KVTxn) Append(key []byte, value []byte) []byte
  • func (kv *KVTxn) Dels(keys ...[]byte) error
  • func (kv *KVTxn) Exist(Prefix []byte) bool
  • func (kv *KVTxn) Get(key []byte) []byte
  • func (kv *KVTxn) IncrBy(key []byte, value int64) int64
  • func (kv *KVTxn) ScanValues(prefix []byte) (map[string][]byte, error)
  • func (kv *KVTxn) Set(key, value []byte) error
• type KvClient
  • func NewBadgerClient(config Config) (KvClient, error)
• type KvTxn

Constants

const (
	MemType  = "mem"
	DiskType = "disk"
)

Types

type Config

type Config struct {
	FsID      string
	Driver    string
	CachePath string
	Capacity  int64
}

type KVTxn

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

func (*KVTxn) Append

func (kv *KVTxn) Append(key []byte, value []byte) []byte

func (*KVTxn) Dels

func (kv *KVTxn) Dels(keys ...[]byte) error

func (*KVTxn) Exist

func (kv *KVTxn) Exist(Prefix []byte) bool

func (*KVTxn) Get

func (kv *KVTxn) Get(key []byte) []byte

func (*KVTxn) IncrBy

func (kv *KVTxn) IncrBy(key []byte, value int64) int64

func (*KVTxn) ScanValues

func (kv *KVTxn) ScanValues(prefix []byte) (map[string][]byte, error)

func (*KVTxn) Set

func (kv *KVTxn) Set(key, value []byte) error

type KvClient

type KvClient interface {
	Name() string
	Txn(f func(KvTxn) error) error
}

func NewBadgerClient

func NewBadgerClient(config Config) (KvClient, error)

type KvTxn

type KvTxn interface {
	Get(key []byte) []byte
	Set(key, value []byte) error
	Dels(keys ...[]byte) error
	ScanValues(prefix []byte) (map[string][]byte, error)
	Exist(Prefix []byte) bool
	Append(key []byte, value []byte) []byte
	IncrBy(key []byte, value int64) int64
}