Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mocktikv

package

Go to main page

Versions in this module

v2

v2.5.4

Dec 8, 2022

v2.5.3

Dec 7, 2022

v2.5.2

Dec 7, 2022

v2.5.1

Dec 1, 2022

v2.5.0

Dec 1, 2022

v2.1.0

Dec 1, 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