protocol

Documentation

Index

• type CFHandle
  • func NewCFHandle(name string, handle gokvstore.KVQueryCommandStore) (cfHandle *CFHandle)
  • func (self *CFHandle) DeleteBetweenToWriteBatch(begKey, endKey []byte, returnDeletedKeys bool, batch gokvstore.WriteBatch) (deletedKeys [][]byte, err error)
  • func (self *CFHandle) DeleteMultiToWriteBatch(keys [][]byte, batch gokvstore.WriteBatch) (err error)
  • func (self *CFHandle) DeleteToWriteBatch(key []byte, batch gokvstore.WriteBatch) (err error)
  • func (self *CFHandle) Get(key []byte) (value []byte, err error)
  • func (self *CFHandle) GetMulti(keys [][]byte) (values [][]byte, err error)
  • func (self *CFHandle) Iterator(sortOrder goiterator.IteratorSortOrder, readaheadLimitByteSize uint64, ...) goiterator.KVIndexedBulkIterator
  • func (self *CFHandle) Name() string
  • func (self *CFHandle) PutMultiToWriteBatch(keys, values [][]byte, batch gokvstore.WriteBatch) (err error)
  • func (self *CFHandle) PutToWriteBatch(key, value []byte, batch gokvstore.WriteBatch) (err error)
  • func (self *CFHandle) UnderlyingHandle() interface{}

Types

type CFHandle

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

func NewCFHandle

func NewCFHandle(
	name string,
	handle gokvstore.KVQueryCommandStore,
) (cfHandle *CFHandle)

func (*CFHandle) DeleteBetweenToWriteBatch

func (self *CFHandle) DeleteBetweenToWriteBatch(
	begKey, endKey []byte, returnDeletedKeys bool, batch gokvstore.WriteBatch) (deletedKeys [][]byte, err error)

func (*CFHandle) DeleteMultiToWriteBatch

func (self *CFHandle) DeleteMultiToWriteBatch(keys [][]byte, batch gokvstore.WriteBatch) (err error)

func (*CFHandle) DeleteToWriteBatch

func (self *CFHandle) DeleteToWriteBatch(key []byte, batch gokvstore.WriteBatch) (err error)

func (*CFHandle) Get

func (self *CFHandle) Get(key []byte) (value []byte, err error)

func (*CFHandle) GetMulti

func (self *CFHandle) GetMulti(keys [][]byte) (values [][]byte, err error)

func (*CFHandle) Iterator

func (self *CFHandle) Iterator(
	sortOrder goiterator.IteratorSortOrder,
	readaheadLimitByteSize uint64,
	readaheadLimitCnt uint64,
	elems ...gokvstore.IteratorElementInfo) goiterator.KVIndexedBulkIterator

Iterator creates and allocates a new KVBulkIterator with the given elems as basis, the implementation is dependent on the underlying store.

func (*CFHandle) Name

func (self *CFHandle) Name() string

func (*CFHandle) PutMultiToWriteBatch

func (self *CFHandle) PutMultiToWriteBatch(keys, values [][]byte, batch gokvstore.WriteBatch) (err error)

func (*CFHandle) PutToWriteBatch

func (self *CFHandle) PutToWriteBatch(key, value []byte, batch gokvstore.WriteBatch) (err error)

func (*CFHandle) UnderlyingHandle

func (self *CFHandle) UnderlyingHandle() interface{}