mock

package
v3.1.0-fork Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package mock is just for test only.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	kv.RequestTypeSupportedChecker
	MockResponse kv.Response
}

Client implement kv.Client interface, mocked from "CopClient" defined in "store/tikv/copprocessor.go".

func (*Client) Send

func (c *Client) Send(ctx context.Context, req *kv.Request, kv *kv.Variables) kv.Response

Send implement kv.Client interface.

type Context

type Context struct {
	Store kv.Storage // mock global variable
	// contains filtered or unexported fields
}

Context represents mocked sessionctx.Context.

func NewContext

func NewContext() *Context

NewContext creates a new mocked sessionctx.Context.

func (*Context) AddTableLock

func (c *Context) AddTableLock(_ []model.TableLockTpInfo)

AddTableLock implements the sessionctx.Context interface.

func (*Context) Cancel

func (c *Context) Cancel()

Cancel implements the Session interface.

func (*Context) CheckTableLocked

func (c *Context) CheckTableLocked(_ int64) (bool, model.TableLockType)

CheckTableLocked implements the sessionctx.Context interface.

func (*Context) ClearValue

func (c *Context) ClearValue(key fmt.Stringer)

ClearValue implements sessionctx.Context ClearValue interface.

func (*Context) Close

func (c *Context) Close()

Close implements the sessionctx.Context interface.

func (*Context) DDLOwnerChecker

func (c *Context) DDLOwnerChecker() owner.DDLOwnerChecker

DDLOwnerChecker returns owner.DDLOwnerChecker.

func (*Context) Execute

func (c *Context) Execute(ctx context.Context, sql string) ([]sqlexec.RecordSet, error)

Execute implements sqlexec.SQLExecutor Execute interface.

func (*Context) ExecuteInternal

func (c *Context) ExecuteInternal(ctx context.Context, sql string) ([]sqlexec.RecordSet, error)

ExecuteInternal implements sqlexec.SQLExecutor ExecuteInternal interface.

func (*Context) GetAllTableLocks

func (c *Context) GetAllTableLocks() []model.TableLockTpInfo

GetAllTableLocks implements the sessionctx.Context interface.

func (*Context) GetClient

func (c *Context) GetClient() kv.Client

GetClient implements sessionctx.Context GetClient interface.

func (*Context) GetGlobalSysVar

func (c *Context) GetGlobalSysVar(ctx sessionctx.Context, name string) (string, error)

GetGlobalSysVar implements GlobalVarAccessor GetGlobalSysVar interface.

func (*Context) GetSessionManager

func (c *Context) GetSessionManager() util.SessionManager

GetSessionManager implements the sessionctx.Context interface.

func (*Context) GetSessionVars

func (c *Context) GetSessionVars() *variable.SessionVars

GetSessionVars implements the sessionctx.Context GetSessionVars interface.

func (*Context) GetStore

func (c *Context) GetStore() kv.Storage

GetStore gets the store of session.

func (*Context) GoCtx

func (c *Context) GoCtx() context.Context

GoCtx returns standard sessionctx.Context that bind with current transaction.

func (*Context) HasDirtyContent

func (c *Context) HasDirtyContent(tid int64) bool

HasDirtyContent implements sessionctx.Context ClearValue interface.

func (*Context) HasLockedTables

func (c *Context) HasLockedTables() bool

HasLockedTables implements the sessionctx.Context interface.

func (*Context) InitTxnWithStartTS

func (c *Context) InitTxnWithStartTS(startTS uint64) error

InitTxnWithStartTS implements the sessionctx.Context interface with startTS.

func (*Context) NewTxn

func (c *Context) NewTxn(context.Context) error

NewTxn implements the sessionctx.Context interface.

func (*Context) PrepareTSFuture

func (c *Context) PrepareTSFuture(ctx context.Context)

PrepareTSFuture implements the sessionctx.Context interface.

func (*Context) PreparedPlanCache

func (c *Context) PreparedPlanCache() *kvcache.SimpleLRUCache

PreparedPlanCache implements the sessionctx.Context interface.

func (*Context) RefreshTxnCtx

func (c *Context) RefreshTxnCtx(ctx context.Context) error

RefreshTxnCtx implements the sessionctx.Context interface.

func (*Context) ReleaseAllTableLocks

func (c *Context) ReleaseAllTableLocks()

ReleaseAllTableLocks implements the sessionctx.Context interface.

func (*Context) ReleaseTableLockByTableIDs

func (c *Context) ReleaseTableLockByTableIDs(tableIDs []int64)

ReleaseTableLockByTableIDs implements the sessionctx.Context interface.

func (*Context) ReleaseTableLocks

func (c *Context) ReleaseTableLocks(locks []model.TableLockTpInfo)

ReleaseTableLocks implements the sessionctx.Context interface.

func (*Context) SetGlobalSysVar

func (c *Context) SetGlobalSysVar(ctx sessionctx.Context, name string, value string) error

SetGlobalSysVar implements GlobalVarAccessor SetGlobalSysVar interface.

func (*Context) SetSessionManager

func (c *Context) SetSessionManager(sm util.SessionManager)

SetSessionManager set the session manager.

func (*Context) SetValue

func (c *Context) SetValue(key fmt.Stringer, value interface{})

SetValue implements sessionctx.Context SetValue interface.

func (*Context) StmtAddDirtyTableOP

func (c *Context) StmtAddDirtyTableOP(op int, tid int64, handle int64)

StmtAddDirtyTableOP implements the sessionctx.Context interface.

func (*Context) StmtCommit

func (c *Context) StmtCommit(tracker *memory.Tracker) error

StmtCommit implements the sessionctx.Context interface.

func (*Context) StmtGetMutation

func (c *Context) StmtGetMutation(tableID int64) *binlog.TableMutation

StmtGetMutation implements the sessionctx.Context interface.

func (*Context) StmtRollback

func (c *Context) StmtRollback()

StmtRollback implements the sessionctx.Context interface.

func (*Context) StoreQueryFeedback

func (c *Context) StoreQueryFeedback(_ interface{})

StoreQueryFeedback stores the query feedback.

func (*Context) Txn

func (c *Context) Txn(bool) (kv.Transaction, error)

Txn implements sessionctx.Context Txn interface.

func (*Context) Value

func (c *Context) Value(key fmt.Stringer) interface{}

Value implements sessionctx.Context Value interface.

type HookKeyForTest

type HookKeyForTest string

HookKeyForTest is as alias, used by context.WithValue. golint forbits using string type as key in context.WithValue.

type Store

type Store struct {
	Client kv.Client
}

Store implements kv.Storage interface.

func (*Store) Begin

func (s *Store) Begin() (kv.Transaction, error)

Begin implements kv.Storage interface.

func (*Store) BeginWithStartTS

func (s *Store) BeginWithStartTS(startTS uint64) (kv.Transaction, error)

BeginWithStartTS implements kv.Storage interface.

func (*Store) Close

func (s *Store) Close() error

Close implements kv.Storage interface.

func (*Store) CurrentVersion

func (s *Store) CurrentVersion() (kv.Version, error)

CurrentVersion implements kv.Storage interface.

func (*Store) Describe

func (s *Store) Describe() string

Describe implements kv.Storage interface.

func (*Store) GetClient

func (s *Store) GetClient() kv.Client

GetClient implements kv.Storage interface.

func (*Store) GetOracle

func (s *Store) GetOracle() oracle.Oracle

GetOracle implements kv.Storage interface.

func (*Store) GetSnapshot

func (s *Store) GetSnapshot(ver kv.Version) (kv.Snapshot, error)

GetSnapshot implements kv.Storage interface.

func (*Store) Name

func (s *Store) Name() string

Name implements kv.Storage interface.

func (*Store) ShowStatus

func (s *Store) ShowStatus(ctx context.Context, key string) (interface{}, error)

ShowStatus implements kv.Storage interface.

func (*Store) SupportDeleteRange

func (s *Store) SupportDeleteRange() bool

SupportDeleteRange implements kv.Storage interface.

func (*Store) UUID

func (s *Store) UUID() string

UUID implements kv.Storage interface.

Jump to

Keyboard shortcuts

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