mock

Documentation

Overview

Package mock is just for test only.

Index

• type Client
  • func (c *Client) IsRequestTypeSupported(reqType, subType int64) bool
  • func (c *Client) Send(ctx context.Context, req *kv.Request, kv *kv.Variables) kv.Response
• type Context
  • func NewContext() *Context
  • func (c *Context) ActivePendingTxn() error
  • func (c *Context) Cancel()
  • func (c *Context) ClearValue(key fmt.Stringer)
  • func (c *Context) DDLOwnerChecker() owner.DDLOwnerChecker
  • func (c *Context) Execute(ctx context.Context, sql string) ([]ast.RecordSet, error)
  • func (c *Context) GetClient() kv.Client
  • func (c *Context) GetGlobalSysVar(ctx sessionctx.Context, name string) (string, error)
  • func (c *Context) GetSessionManager() util.SessionManager
  • func (c *Context) GetSessionVars() *variable.SessionVars
  • func (c *Context) GetStore() kv.Storage
  • func (c *Context) GoCtx() context.Context
  • func (c *Context) InitTxnWithStartTS(startTS uint64) error
  • func (c *Context) NewTxn() error
  • func (c *Context) PreparedPlanCache() *kvcache.SimpleLRUCache
  • func (c *Context) RefreshTxnCtx(ctx context.Context) error
  • func (c *Context) SetGlobalSysVar(ctx sessionctx.Context, name string, value string) error
  • func (c *Context) SetSessionManager(sm util.SessionManager)
  • func (c *Context) SetValue(key fmt.Stringer, value interface{})
  • func (c *Context) StmtAddDirtyTableOP(op int, tid int64, handle int64, row []types.Datum)
  • func (c *Context) StmtCommit()
  • func (c *Context) StmtGetMutation(tableID int64) *binlog.TableMutation
  • func (c *Context) StmtRollback()
  • func (c *Context) StoreQueryFeedback(_ interface{})
  • func (c *Context) Txn() kv.Transaction
  • func (c *Context) Value(key fmt.Stringer) interface{}
• type HookKeyForTest
• type Store
  • func (s *Store) Begin() (kv.Transaction, error)
  • func (s *Store) BeginWithStartTS(startTS uint64) (kv.Transaction, error)
  • func (s *Store) Close() error
  • func (s *Store) CurrentVersion() (kv.Version, error)
  • func (s *Store) GetClient() kv.Client
  • func (s *Store) GetOracle() oracle.Oracle
  • func (s *Store) GetSnapshot(ver kv.Version) (kv.Snapshot, error)
  • func (s *Store) SupportDeleteRange() bool
  • func (s *Store) UUID() string

Types

type Client

type Client struct {
	MockResponse kv.Response
}

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

func (*Client) IsRequestTypeSupported

func (c *Client) IsRequestTypeSupported(reqType, subType int64) bool

IsRequestTypeSupported implement kv.Client interface.

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) ActivePendingTxn

func (c *Context) ActivePendingTxn() error

ActivePendingTxn implements the sessionctx.Context interface.

func (*Context) Cancel

func (c *Context) Cancel()

Cancel implements the Session interface.

func (*Context) ClearValue

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

ClearValue implements sessionctx.Context ClearValue 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) ([]ast.RecordSet, error)

Execute implements sqlexec.SQLExecutor Execute 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) InitTxnWithStartTS

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

InitTxnWithStartTS implements the sessionctx.Context interface with startTS.

func (*Context) NewTxn

func (c *Context) NewTxn() error

NewTxn 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) 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, row []types.Datum)

StmtAddDirtyTableOP implements the sessionctx.Context interface.

func (*Context) StmtCommit

func (c *Context) StmtCommit()

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() kv.Transaction

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) 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) SupportDeleteRange

func (s *Store) SupportDeleteRange() bool

SupportDeleteRange implements kv.Storage interface.

func (*Store) UUID

func (s *Store) UUID() string

UUID implements kv.Storage interface.