Versions in this module Expand all Collapse all v1 v1.0.1 Sep 26, 2022 Changes in this version + var ErrClientNotFound = errors.New("client not found") + var ErrIterNotFound = errors.New("iterator not found") + var ErrTxnNotFound = errors.New("txn not found") + type ContextKey int + var UUIDKey ContextKey = 1 + type RawKVProxy struct + func NewRaw() RawKVProxy + func (p RawKVProxy) BatchDelete(ctx context.Context, keys [][]byte) error + func (p RawKVProxy) BatchGet(ctx context.Context, keys [][]byte) ([][]byte, error) + func (p RawKVProxy) BatchPut(ctx context.Context, keys, values [][]byte) error + func (p RawKVProxy) Close(ctx context.Context) error + func (p RawKVProxy) Delete(ctx context.Context, key []byte) error + func (p RawKVProxy) DeleteRange(ctx context.Context, startKey []byte, endKey []byte) error + func (p RawKVProxy) Get(ctx context.Context, key []byte) ([]byte, error) + func (p RawKVProxy) New(ctx context.Context, pdAddrs []string, conf config.Config) (UUID, error) + func (p RawKVProxy) Put(ctx context.Context, key, value []byte) error + func (p RawKVProxy) ReverseScan(ctx context.Context, startKey, endKey []byte, limit int) ([][]byte, [][]byte, error) + func (p RawKVProxy) Scan(ctx context.Context, startKey, endKey []byte, limit int) ([][]byte, [][]byte, error) + type TxnKVProxy struct + func NewTxn() TxnKVProxy + func (p TxnKVProxy) Begin(ctx context.Context) (UUID, error) + func (p TxnKVProxy) BeginWithTS(ctx context.Context, ts uint64) (UUID, error) + func (p TxnKVProxy) Close(ctx context.Context) error + func (p TxnKVProxy) GetTS(ctx context.Context) (uint64, error) + func (p TxnKVProxy) IterClose(ctx context.Context) error + func (p TxnKVProxy) IterKey(ctx context.Context) ([]byte, error) + func (p TxnKVProxy) IterNext(ctx context.Context) error + func (p TxnKVProxy) IterValid(ctx context.Context) (bool, error) + func (p TxnKVProxy) IterValue(ctx context.Context) ([]byte, error) + func (p TxnKVProxy) New(ctx context.Context, pdAddrs []string, conf config.Config) (UUID, error) + func (p TxnKVProxy) TxnBatchGet(ctx context.Context, keys [][]byte) (map[string][]byte, error) + func (p TxnKVProxy) TxnCommit(ctx context.Context) error + func (p TxnKVProxy) TxnDelete(ctx context.Context, key []byte) error + func (p TxnKVProxy) TxnGet(ctx context.Context, key []byte) ([]byte, error) + func (p TxnKVProxy) TxnIsReadOnly(ctx context.Context) (bool, error) + func (p TxnKVProxy) TxnIter(ctx context.Context, key []byte, upperBound []byte) (UUID, error) + func (p TxnKVProxy) TxnIterReverse(ctx context.Context, key []byte) (UUID, error) + func (p TxnKVProxy) TxnLen(ctx context.Context) (int, error) + func (p TxnKVProxy) TxnLockKeys(ctx context.Context, keys [][]byte) error + func (p TxnKVProxy) TxnRollback(ctx context.Context) error + func (p TxnKVProxy) TxnSet(ctx context.Context, k []byte, v []byte) error + func (p TxnKVProxy) TxnSize(ctx context.Context) (int, error) + func (p TxnKVProxy) TxnValid(ctx context.Context) (bool, error) + type UUID string
Go to main page