mocktikv

package

Go to main page

Versions in this module

v2

v2.0.7

Apr 14, 2023

v2.0.6

Mar 2, 2023

v2.0.5

Feb 2, 2023

v2.0.4

Jan 6, 2023

Changes in this version

type Cluster

+ func (c *Cluster) UpdateStorePeerAddr(storeID uint64, peerAddr string, labels ...*metapb.StoreLabel)

type ErrConflict

+ CanForceLock bool

v2.0.3

Dec 8, 2022

v2.0.2

Nov 2, 2022

Changes in this version

type Cluster

+ func (c *Cluster) SplitRegionBuckets(regionID uint64, keys [][]byte, bucketVer uint64)

+ type ErrAssertionFailed struct

+ Assertion kvrpcpb.Assertion

+ ExistingCommitTS uint64

+ ExistingStartTS uint64

+ Key []byte

+ StartTS uint64

+ func (e *ErrAssertionFailed) Error() string

type MVCCLevelDB

+ func (mvcc *MVCCLevelDB) RawChecksum(cf string, startKey, endKey []byte) (uint64, uint64, uint64, error)

+ func (mvcc *MVCCLevelDB) RawCompareAndSwap(cf string, key, expectedValue, newValue []byte) (oldValue []byte, swapped bool, err error)

type RPCClient

+ func (c *RPCClient) CloseAddr(addr string) error

type RawKV

+ RawChecksum func(cf string, startKey, endKey []byte) (uint64, uint64, uint64, error)

+ RawCompareAndSwap func(cf string, key, expectedValue, newvalue []byte) ([]byte, bool, error)

type Region

+ Buckets *metapb.Buckets

v2.0.1

Apr 7, 2022

v2.0.0

Feb 24, 2022

Changes in this version

+ var ErrInvalidEncodedKey = errors.New("invalid encoded key")

+ var LockAlwaysWait = int64(0)

+ var LockNoWait = int64(-1)

+ var PutMutations = putMutations

+ func BootstrapWithMultiRegions(cluster *Cluster, splitKeys ...[]byte) (storeID uint64, regionIDs, peerIDs []uint64)

+ func BootstrapWithMultiStores(cluster *Cluster, n int) (storeIDs, peerIDs []uint64, regionID uint64, leaderPeer uint64)

+ func BootstrapWithSingleStore(cluster *Cluster) (storeID, peerID, regionID uint64)

+ func MustPrewrite(store MVCCStore, mutations []*kvrpcpb.Mutation, primary string, startTS uint64, ...) bool

+ func NewPDClient(cluster *Cluster) pd.Client

+ func NewTiKVAndPDClient(path string, coprHandler CoprRPCHandler) (*RPCClient, *Cluster, pd.Client, error)

+ type Client interface

+ Close func() error

+ SendRequest func(ctx context.Context, addr string, req *tikvrpc.Request, timeout time.Duration) (*tikvrpc.Response, error)

+ type Cluster struct

+ func NewCluster(mvccStore MVCCStore) *Cluster

+ func (c *Cluster) AddPeer(regionID, storeID, peerID uint64)

+ func (c *Cluster) AddStore(storeID uint64, addr string, labels ...*metapb.StoreLabel)

+ func (c *Cluster) AllocID() uint64

+ func (c *Cluster) AllocIDs(n int) []uint64

+ func (c *Cluster) Bootstrap(regionID uint64, storeIDs, peerIDs []uint64, leaderPeerID uint64)

+ func (c *Cluster) CancelStore(storeID uint64)

+ func (c *Cluster) ChangeLeader(regionID, leaderPeerID uint64)

+ func (c *Cluster) GetAllRegions() []*Region

+ func (c *Cluster) GetAllStores() []*metapb.Store

+ func (c *Cluster) GetAndCheckStoreByAddr(addr string) (ss []*metapb.Store, err error)

+ func (c *Cluster) GetPrevRegionByKey(key []byte) (*metapb.Region, *metapb.Peer)

+ func (c *Cluster) GetRegion(regionID uint64) (*metapb.Region, uint64)

+ func (c *Cluster) GetRegionByID(regionID uint64) (*metapb.Region, *metapb.Peer)

+ func (c *Cluster) GetRegionByKey(key []byte) (*metapb.Region, *metapb.Peer)

+ func (c *Cluster) GetStore(storeID uint64) *metapb.Store

+ func (c *Cluster) GetStoreByAddr(addr string) *metapb.Store

+ func (c *Cluster) GiveUpLeader(regionID uint64)

+ func (c *Cluster) MarkTombstone(storeID uint64)

+ func (c *Cluster) Merge(regionID1, regionID2 uint64)

+ func (c *Cluster) RemovePeer(regionID, storeID uint64)

+ func (c *Cluster) RemoveStore(storeID uint64)

+ func (c *Cluster) ScanRegions(startKey, endKey []byte, limit int) []*pd.Region

+ func (c *Cluster) ScheduleDelay(startTS, regionID uint64, dur time.Duration)

+ func (c *Cluster) Split(regionID, newRegionID uint64, key []byte, peerIDs []uint64, ...)

+ func (c *Cluster) SplitKeys(start, end []byte, count int)

+ func (c *Cluster) SplitRaw(regionID, newRegionID uint64, rawKey []byte, peerIDs []uint64, ...) *metapb.Region

+ func (c *Cluster) StartStore(storeID uint64)

+ func (c *Cluster) StopStore(storeID uint64)

+ func (c *Cluster) UnCancelStore(storeID uint64)

+ func (c *Cluster) UpdateStoreAddr(storeID uint64, addr string, labels ...*metapb.StoreLabel)

+ func (c *Cluster) UpdateStoreLabels(storeID uint64, labels []*metapb.StoreLabel)

+ type CoprRPCHandler interface

+ Close func()

+ HandleBatchCop func(ctx context.Context, reqCtx *kvrpcpb.Context, session *Session, ...) (*tikvrpc.BatchCopStreamResponse, error)

+ HandleCmdCop func(reqCtx *kvrpcpb.Context, session *Session, r *coprocessor.Request) *coprocessor.Response

+ HandleCopStream func(ctx context.Context, reqCtx *kvrpcpb.Context, session *Session, ...) (*tikvrpc.CopStreamResponse, error)

+ type ErrAbort string

+ func (e ErrAbort) Error() string

+ type ErrAlreadyCommitted uint64

+ func (e ErrAlreadyCommitted) Error() string

+ type ErrAlreadyRollbacked struct

+ func (e *ErrAlreadyRollbacked) Error() string

+ type ErrCommitTSExpired struct

+ func (e *ErrCommitTSExpired) Error() string

+ type ErrConflict struct

+ ConflictCommitTS uint64

+ ConflictTS uint64

+ Key []byte

+ StartTS uint64

+ func (e *ErrConflict) Error() string

+ type ErrDeadlock struct

+ DealockKeyHash uint64

+ LockKey []byte

+ LockTS uint64

+ func (e *ErrDeadlock) Error() string

+ type ErrKeyAlreadyExist struct

+ Key []byte

+ func (e *ErrKeyAlreadyExist) Error() string

+ type ErrLocked struct

+ ForUpdateTS uint64

+ Key MvccKey

+ LockType kvrpcpb.Op

+ Primary []byte

+ StartTS uint64

+ TTL uint64

+ TxnSize uint64

+ func (e *ErrLocked) Error() string

+ type ErrRetryable string

+ func (e ErrRetryable) Error() string

+ type ErrTxnNotFound struct

+ func (e *ErrTxnNotFound) Error() string

+ type Iterator struct

+ func (iter *Iterator) Next()

+ func (iter *Iterator) Valid() bool

+ type MVCCDebugger interface

+ MvccGetByKey func(key []byte) *kvrpcpb.MvccInfo

+ MvccGetByStartTS func(starTS uint64) (*kvrpcpb.MvccInfo, []byte)

+ type MVCCLevelDB struct

+ func NewMVCCLevelDB(path string) (*MVCCLevelDB, error)

+ func (mvcc *MVCCLevelDB) BatchGet(ks [][]byte, startTS uint64, isoLevel kvrpcpb.IsolationLevel, ...) []Pair

+ func (mvcc *MVCCLevelDB) BatchResolveLock(startKey, endKey []byte, txnInfos map[uint64]uint64) error

+ func (mvcc *MVCCLevelDB) CheckTxnStatus(primaryKey []byte, lockTS, callerStartTS, currentTS uint64, ...) (ttl uint64, commitTS uint64, action kvrpcpb.Action, err error)

+ func (mvcc *MVCCLevelDB) Cleanup(key []byte, startTS, currentTS uint64) error

+ func (mvcc *MVCCLevelDB) Close() error

+ func (mvcc *MVCCLevelDB) Commit(keys [][]byte, startTS, commitTS uint64) error

+ func (mvcc *MVCCLevelDB) DeleteRange(startKey, endKey []byte) error

+ func (mvcc *MVCCLevelDB) GC(startKey, endKey []byte, safePoint uint64) error

+ func (mvcc *MVCCLevelDB) Get(key []byte, startTS uint64, isoLevel kvrpcpb.IsolationLevel, ...) ([]byte, error)

+ func (mvcc *MVCCLevelDB) MvccGetByKey(key []byte) *kvrpcpb.MvccInfo

+ func (mvcc *MVCCLevelDB) MvccGetByStartTS(starTS uint64) (*kvrpcpb.MvccInfo, []byte)

+ func (mvcc *MVCCLevelDB) PessimisticLock(req *kvrpcpb.PessimisticLockRequest) *kvrpcpb.PessimisticLockResponse

+ func (mvcc *MVCCLevelDB) PessimisticRollback(keys [][]byte, startTS, forUpdateTS uint64) []error

+ func (mvcc *MVCCLevelDB) Prewrite(req *kvrpcpb.PrewriteRequest) []error

+ func (mvcc *MVCCLevelDB) RawBatchDelete(keys [][]byte)

+ func (mvcc *MVCCLevelDB) RawBatchGet(keys [][]byte) [][]byte

+ func (mvcc *MVCCLevelDB) RawBatchPut(keys, values [][]byte)

+ func (mvcc *MVCCLevelDB) RawDelete(key []byte)

+ func (mvcc *MVCCLevelDB) RawDeleteRange(startKey, endKey []byte)

+ func (mvcc *MVCCLevelDB) RawGet(key []byte) []byte

+ func (mvcc *MVCCLevelDB) RawPut(key, value []byte)

+ func (mvcc *MVCCLevelDB) RawReverseScan(startKey, endKey []byte, limit int) []Pair

+ func (mvcc *MVCCLevelDB) RawScan(startKey, endKey []byte, limit int) []Pair

+ func (mvcc *MVCCLevelDB) ResolveLock(startKey, endKey []byte, startTS, commitTS uint64) error

+ func (mvcc *MVCCLevelDB) ReverseScan(startKey, endKey []byte, limit int, startTS uint64, ...) []Pair

+ func (mvcc *MVCCLevelDB) Rollback(keys [][]byte, startTS uint64) error

+ func (mvcc *MVCCLevelDB) Scan(startKey, endKey []byte, limit int, startTS uint64, ...) []Pair

+ func (mvcc *MVCCLevelDB) ScanLock(startKey, endKey []byte, maxTS uint64) ([]*kvrpcpb.LockInfo, error)

+ func (mvcc *MVCCLevelDB) TxnHeartBeat(key []byte, startTS uint64, adviseTTL uint64) (uint64, error)

+ type MVCCStore interface

+ BatchGet func(ks [][]byte, startTS uint64, isoLevel kvrpcpb.IsolationLevel, ...) []Pair

+ BatchResolveLock func(startKey, endKey []byte, txnInfos map[uint64]uint64) error

+ CheckTxnStatus func(primaryKey []byte, lockTS uint64, startTS, currentTS uint64, ...) (uint64, uint64, kvrpcpb.Action, error)

+ Cleanup func(key []byte, startTS, currentTS uint64) error

+ Close func() error

+ Commit func(keys [][]byte, startTS, commitTS uint64) error

+ DeleteRange func(startKey, endKey []byte) error

+ GC func(startKey, endKey []byte, safePoint uint64) error

+ Get func(key []byte, startTS uint64, isoLevel kvrpcpb.IsolationLevel, ...) ([]byte, error)

+ PessimisticLock func(req *kvrpcpb.PessimisticLockRequest) *kvrpcpb.PessimisticLockResponse

+ PessimisticRollback func(keys [][]byte, startTS, forUpdateTS uint64) []error

+ Prewrite func(req *kvrpcpb.PrewriteRequest) []error

+ ResolveLock func(startKey, endKey []byte, startTS, commitTS uint64) error

+ ReverseScan func(startKey, endKey []byte, limit int, startTS uint64, ...) []Pair

+ Rollback func(keys [][]byte, startTS uint64) error

+ Scan func(startKey, endKey []byte, limit int, startTS uint64, ...) []Pair

+ ScanLock func(startKey, endKey []byte, maxTS uint64) ([]*kvrpcpb.LockInfo, error)

+ TxnHeartBeat func(primaryKey []byte, startTS uint64, adviseTTL uint64) (uint64, error)

+ func MustNewMVCCStore() MVCCStore

+ type MvccKey []byte

+ func NewMvccKey(key []byte) MvccKey

+ func (key MvccKey) Raw() []byte

+ type Pair struct

+ Err error

+ Key []byte

+ Value []byte

+ type RPCClient struct

+ Cluster *Cluster

+ MvccStore MVCCStore

+ func NewRPCClient(cluster *Cluster, mvccStore MVCCStore, coprHandler CoprRPCHandler) *RPCClient

+ func (c *RPCClient) Close() error

+ func (c *RPCClient) SendRequest(ctx context.Context, addr string, req *tikvrpc.Request, timeout time.Duration) (*tikvrpc.Response, error)

+ type RawKV interface

+ RawBatchDelete func(keys [][]byte)

+ RawBatchGet func(keys [][]byte) [][]byte

+ RawBatchPut func(keys, values [][]byte)

+ RawDelete func(key []byte)

+ RawDeleteRange func(startKey, endKey []byte)

+ RawGet func(key []byte) []byte

+ RawPut func(key, value []byte)

+ RawReverseScan func(startKey, endKey []byte, limit int) []Pair

+ RawScan func(startKey, endKey []byte, limit int) []Pair

+ type Region struct

+ Meta *metapb.Region

+ type Session struct

+ func (s *Session) CheckRequestContext(ctx *kvrpcpb.Context) *errorpb.Error

+ func (s *Session) GetIsolationLevel() kvrpcpb.IsolationLevel

+ func (s *Session) GetMVCCStore() MVCCStore

+ func (s *Session) GetRawEndKey() []byte

+ func (s *Session) GetRawStartKey() []byte

+ func (s *Session) GetResolvedLocks() []uint64

+ type Store struct

v2.0.0-rc

Dec 6, 2021

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