kv_bitable

Documentation

Index

• Variables
• func NewKVStore(sPath string, cfg *dbconfig.Config, dataType btools.DataType, dbType int) (kv.IKVStore, error)
• type KV
  • func (r *KV) AsyncFlush() (<-chan struct{}, error)
  • func (r *KV) CacheInfo() string
  • func (r *KV) Checkpoint(destDir string) error
  • func (r *KV) Close() error
  • func (r *KV) Compact(_ int)
  • func (r *KV) DebugInfo() string
  • func (r *KV) Delete(key []byte) error
  • func (r *KV) Flush() error
  • func (r *KV) Get(key []byte) ([]byte, error)
  • func (r *KV) GetPools(key []byte) ([]byte, func(), error)
  • func (r *KV) GetValue(key []byte) ([]byte, error)
  • func (r *KV) GetWriteBatch() kv.IWriteBatch
  • func (r *KV) Id() int
  • func (r *KV) IsExist(key []byte) (bool, error)
  • func (r *KV) IsNotFound(err error) bool
  • func (r *KV) MGet(keys ...[]byte) ([][]byte, error)
  • func (r *KV) MetricsInfo() kv.MetricsInfo
  • func (r *KV) NewIter(o *kv.IteratorOptions) kv.IIterator
  • func (r *KV) Set(key []byte, value []byte) error
  • func (r *KV) SetAutoCompact(val bool)
  • func (r *KV) SetCheckpointHighPriority(v bool)
  • func (r *KV) SetCheckpointLock(v bool)

Variables

var ErrNotFound = bitalostable.ErrNotFound

Functions

func NewKVStore

func NewKVStore(sPath string, cfg *dbconfig.Config,
	dataType btools.DataType, dbType int) (kv.IKVStore, error)

Types

type KV

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

func (*KV) AsyncFlush

func (r *KV) AsyncFlush() (<-chan struct{}, error)

func (*KV) CacheInfo

func (r *KV) CacheInfo() string

func (*KV) Checkpoint

func (r *KV) Checkpoint(destDir string) error

func (*KV) Close

func (r *KV) Close() error

func (*KV) Compact

func (r *KV) Compact(_ int)

func (*KV) DebugInfo

func (r *KV) DebugInfo() string

func (*KV) Delete

func (r *KV) Delete(key []byte) error

func (*KV) Flush

func (r *KV) Flush() error

func (*KV) Get

func (r *KV) Get(key []byte) ([]byte, error)

func (*KV) GetPools

func (r *KV) GetPools(key []byte) ([]byte, func(), error)

func (*KV) GetValue

func (r *KV) GetValue(key []byte) ([]byte, error)

func (*KV) GetWriteBatch

func (r *KV) GetWriteBatch() kv.IWriteBatch

func (*KV) Id

func (r *KV) Id() int

func (*KV) IsExist

func (r *KV) IsExist(key []byte) (bool, error)

func (*KV) IsNotFound

func (r *KV) IsNotFound(err error) bool

func (*KV) MGet

func (r *KV) MGet(keys ...[]byte) ([][]byte, error)

func (*KV) MetricsInfo

func (r *KV) MetricsInfo() kv.MetricsInfo

func (*KV) NewIter

func (r *KV) NewIter(o *kv.IteratorOptions) kv.IIterator

func (*KV) Set

func (r *KV) Set(key []byte, value []byte) error

func (*KV) SetAutoCompact

func (r *KV) SetAutoCompact(val bool)

func (*KV) SetCheckpointHighPriority

func (r *KV) SetCheckpointHighPriority(v bool)

func (*KV) SetCheckpointLock

func (r *KV) SetCheckpointLock(v bool)