mock

package
v4.0.11+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBackend 

type MockBackend struct {
	// contains filtered or unexported fields
}

MockBackend is a mock of AbstractBackend interface

func NewMockBackend 

func NewMockBackend(ctrl *gomock.Controller) *MockBackend

NewMockBackend creates a new mock instance

func (*MockBackend) CheckRequirements 

func (m *MockBackend) CheckRequirements(arg0 context.Context) error

CheckRequirements mocks base method

func (*MockBackend) CleanupEngine 

func (m *MockBackend) CleanupEngine(arg0 context.Context, arg1 uuid.UUID) error

CleanupEngine mocks base method

func (*MockBackend) Close 

func (m *MockBackend) Close()

Close mocks base method

func (*MockBackend) CloseEngine 

func (m *MockBackend) CloseEngine(arg0 context.Context, arg1 uuid.UUID) error

CloseEngine mocks base method

func (*MockBackend) EXPECT 

func (m *MockBackend) EXPECT() *MockBackendMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockBackend) FetchRemoteTableModels 

func (m *MockBackend) FetchRemoteTableModels(arg0 context.Context, arg1 string) ([]*model.TableInfo, error)

FetchRemoteTableModels mocks base method

func (*MockBackend) ImportEngine 

func (m *MockBackend) ImportEngine(arg0 context.Context, arg1 uuid.UUID) error

ImportEngine mocks base method

func (*MockBackend) MakeEmptyRows 

func (m *MockBackend) MakeEmptyRows() backend.Rows

MakeEmptyRows mocks base method

func (*MockBackend) MaxChunkSize 

func (m *MockBackend) MaxChunkSize() int

MaxChunkSize mocks base method

func (*MockBackend) NewEncoder 

func (m *MockBackend) NewEncoder(arg0 table.Table, arg1 *backend.SessionOptions) (backend.Encoder, error)

NewEncoder mocks base method

func (*MockBackend) OpenEngine 

func (m *MockBackend) OpenEngine(arg0 context.Context, arg1 uuid.UUID) error

OpenEngine mocks base method

func (*MockBackend) RetryImportDelay 

func (m *MockBackend) RetryImportDelay() time.Duration

RetryImportDelay mocks base method

func (*MockBackend) ShouldPostProcess 

func (m *MockBackend) ShouldPostProcess() bool

ShouldPostProcess mocks base method

func (*MockBackend) WriteRows 

func (m *MockBackend) WriteRows(arg0 context.Context, arg1 uuid.UUID, arg2 string, arg3 []string, arg4 uint64, arg5 backend.Rows) error

WriteRows mocks base method

type MockBackendMockRecorder 

type MockBackendMockRecorder struct {
	// contains filtered or unexported fields
}

MockBackendMockRecorder is the mock recorder for MockBackend

func (*MockBackendMockRecorder) CheckRequirements 

func (mr *MockBackendMockRecorder) CheckRequirements(arg0 interface{}) *gomock.Call

CheckRequirements indicates an expected call of CheckRequirements

func (*MockBackendMockRecorder) CleanupEngine 

func (mr *MockBackendMockRecorder) CleanupEngine(arg0, arg1 interface{}) *gomock.Call

CleanupEngine indicates an expected call of CleanupEngine

func (*MockBackendMockRecorder) Close 

func (mr *MockBackendMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockBackendMockRecorder) CloseEngine 

func (mr *MockBackendMockRecorder) CloseEngine(arg0, arg1 interface{}) *gomock.Call

CloseEngine indicates an expected call of CloseEngine

func (*MockBackendMockRecorder) FetchRemoteTableModels 

func (mr *MockBackendMockRecorder) FetchRemoteTableModels(arg0, arg1 interface{}) *gomock.Call

FetchRemoteTableModels indicates an expected call of FetchRemoteTableModels

func (*MockBackendMockRecorder) ImportEngine 

func (mr *MockBackendMockRecorder) ImportEngine(arg0, arg1 interface{}) *gomock.Call

ImportEngine indicates an expected call of ImportEngine

func (*MockBackendMockRecorder) MakeEmptyRows 

func (mr *MockBackendMockRecorder) MakeEmptyRows() *gomock.Call

MakeEmptyRows indicates an expected call of MakeEmptyRows

func (*MockBackendMockRecorder) MaxChunkSize 

func (mr *MockBackendMockRecorder) MaxChunkSize() *gomock.Call

MaxChunkSize indicates an expected call of MaxChunkSize

func (*MockBackendMockRecorder) NewEncoder 

func (mr *MockBackendMockRecorder) NewEncoder(arg0, arg1 interface{}) *gomock.Call

NewEncoder indicates an expected call of NewEncoder

func (*MockBackendMockRecorder) OpenEngine 

func (mr *MockBackendMockRecorder) OpenEngine(arg0, arg1 interface{}) *gomock.Call

OpenEngine indicates an expected call of OpenEngine

func (*MockBackendMockRecorder) RetryImportDelay 

func (mr *MockBackendMockRecorder) RetryImportDelay() *gomock.Call

RetryImportDelay indicates an expected call of RetryImportDelay

func (*MockBackendMockRecorder) ShouldPostProcess 

func (mr *MockBackendMockRecorder) ShouldPostProcess() *gomock.Call

ShouldPostProcess indicates an expected call of ShouldPostProcess

func (*MockBackendMockRecorder) WriteRows 

func (mr *MockBackendMockRecorder) WriteRows(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

WriteRows indicates an expected call of WriteRows

type MockEncoder 

type MockEncoder struct {
	// contains filtered or unexported fields
}

MockEncoder is a mock of Encoder interface

func NewMockEncoder 

func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder

NewMockEncoder creates a new mock instance

func (*MockEncoder) Close 

func (m *MockEncoder) Close()

Close mocks base method

func (*MockEncoder) EXPECT 

func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockEncoder) Encode 

func (m *MockEncoder) Encode(arg0 log.Logger, arg1 []types.Datum, arg2 int64, arg3 []int) (backend.Row, error)

Encode mocks base method

type MockEncoderMockRecorder 

type MockEncoderMockRecorder struct {
	// contains filtered or unexported fields
}

MockEncoderMockRecorder is the mock recorder for MockEncoder

func (*MockEncoderMockRecorder) Close 

func (mr *MockEncoderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockEncoderMockRecorder) Encode 

func (mr *MockEncoderMockRecorder) Encode(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Encode indicates an expected call of Encode

type MockExternalStorage 

type MockExternalStorage struct {
	// contains filtered or unexported fields
}

MockExternalStorage is a mock of ExternalStorage interface

func NewMockExternalStorage 

func NewMockExternalStorage(ctrl *gomock.Controller) *MockExternalStorage

NewMockExternalStorage creates a new mock instance

func (*MockExternalStorage) CreateUploader 

func (m *MockExternalStorage) CreateUploader(arg0 context.Context, arg1 string) (storage.Uploader, error)

CreateUploader mocks base method

func (*MockExternalStorage) EXPECT 

func (m *MockExternalStorage) EXPECT() *MockExternalStorageMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockExternalStorage) FileExists 

func (m *MockExternalStorage) FileExists(arg0 context.Context, arg1 string) (bool, error)

FileExists mocks base method

func (*MockExternalStorage) Open 

func (m *MockExternalStorage) Open(arg0 context.Context, arg1 string) (storage.ReadSeekCloser, error)

Open mocks base method

func (*MockExternalStorage) Read 

func (m *MockExternalStorage) Read(arg0 context.Context, arg1 string) ([]byte, error)

Read mocks base method

func (*MockExternalStorage) URI 

func (m *MockExternalStorage) URI() string

URI mocks base method

func (*MockExternalStorage) WalkDir 

func (m *MockExternalStorage) WalkDir(arg0 context.Context, arg1 *storage.WalkOption, arg2 func(string, int64) error) error

WalkDir mocks base method

func (*MockExternalStorage) Write 

func (m *MockExternalStorage) Write(arg0 context.Context, arg1 string, arg2 []byte) error

Write mocks base method

type MockExternalStorageMockRecorder 

type MockExternalStorageMockRecorder struct {
	// contains filtered or unexported fields
}

MockExternalStorageMockRecorder is the mock recorder for MockExternalStorage

func (*MockExternalStorageMockRecorder) CreateUploader 

func (mr *MockExternalStorageMockRecorder) CreateUploader(arg0, arg1 interface{}) *gomock.Call

CreateUploader indicates an expected call of CreateUploader

func (*MockExternalStorageMockRecorder) FileExists 

func (mr *MockExternalStorageMockRecorder) FileExists(arg0, arg1 interface{}) *gomock.Call

FileExists indicates an expected call of FileExists

func (*MockExternalStorageMockRecorder) Open 

func (mr *MockExternalStorageMockRecorder) Open(arg0, arg1 interface{}) *gomock.Call

Open indicates an expected call of Open

func (*MockExternalStorageMockRecorder) Read 

func (mr *MockExternalStorageMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockExternalStorageMockRecorder) URI 

func (mr *MockExternalStorageMockRecorder) URI() *gomock.Call

URI indicates an expected call of URI

func (*MockExternalStorageMockRecorder) WalkDir 

func (mr *MockExternalStorageMockRecorder) WalkDir(arg0, arg1, arg2 interface{}) *gomock.Call

WalkDir indicates an expected call of WalkDir

func (*MockExternalStorageMockRecorder) Write 

func (mr *MockExternalStorageMockRecorder) Write(arg0, arg1, arg2 interface{}) *gomock.Call

Write indicates an expected call of Write

type MockGlue 

type MockGlue struct {
	// contains filtered or unexported fields
}

MockGlue is a mock of Glue interface

func NewMockGlue 

func NewMockGlue(ctrl *gomock.Controller) *MockGlue

NewMockGlue creates a new mock instance

func (*MockGlue) EXPECT 

func (m *MockGlue) EXPECT() *MockGlueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockGlue) GetDB 

func (m *MockGlue) GetDB() (*sql.DB, error)

GetDB mocks base method

func (*MockGlue) GetParser 

func (m *MockGlue) GetParser() *parser.Parser

GetParser mocks base method

func (*MockGlue) GetSQLExecutor 

func (m *MockGlue) GetSQLExecutor() glue.SQLExecutor

GetSQLExecutor mocks base method

func (*MockGlue) GetSession 

func (m *MockGlue) GetSession(arg0 context.Context) (checkpoints.Session, error)

GetSession mocks base method

func (*MockGlue) GetTables 

func (m *MockGlue) GetTables(arg0 context.Context, arg1 string) ([]*model.TableInfo, error)

GetTables mocks base method

func (*MockGlue) OpenCheckpointsDB 

func (m *MockGlue) OpenCheckpointsDB(arg0 context.Context, arg1 *config.Config) (checkpoints.CheckpointsDB, error)

OpenCheckpointsDB mocks base method

func (*MockGlue) OwnsSQLExecutor 

func (m *MockGlue) OwnsSQLExecutor() bool

OwnsSQLExecutor mocks base method

func (*MockGlue) Record 

func (m *MockGlue) Record(arg0 string, arg1 uint64)

Record mocks base method

type MockGlueMockRecorder 

type MockGlueMockRecorder struct {
	// contains filtered or unexported fields
}

MockGlueMockRecorder is the mock recorder for MockGlue

func (*MockGlueMockRecorder) GetDB 

func (mr *MockGlueMockRecorder) GetDB() *gomock.Call

GetDB indicates an expected call of GetDB

func (*MockGlueMockRecorder) GetParser 

func (mr *MockGlueMockRecorder) GetParser() *gomock.Call

GetParser indicates an expected call of GetParser

func (*MockGlueMockRecorder) GetSQLExecutor 

func (mr *MockGlueMockRecorder) GetSQLExecutor() *gomock.Call

GetSQLExecutor indicates an expected call of GetSQLExecutor

func (*MockGlueMockRecorder) GetSession 

func (mr *MockGlueMockRecorder) GetSession(arg0 interface{}) *gomock.Call

GetSession indicates an expected call of GetSession

func (*MockGlueMockRecorder) GetTables 

func (mr *MockGlueMockRecorder) GetTables(arg0, arg1 interface{}) *gomock.Call

GetTables indicates an expected call of GetTables

func (*MockGlueMockRecorder) OpenCheckpointsDB 

func (mr *MockGlueMockRecorder) OpenCheckpointsDB(arg0, arg1 interface{}) *gomock.Call

OpenCheckpointsDB indicates an expected call of OpenCheckpointsDB

func (*MockGlueMockRecorder) OwnsSQLExecutor 

func (mr *MockGlueMockRecorder) OwnsSQLExecutor() *gomock.Call

OwnsSQLExecutor indicates an expected call of OwnsSQLExecutor

func (*MockGlueMockRecorder) Record 

func (mr *MockGlueMockRecorder) Record(arg0, arg1 interface{}) *gomock.Call

Record indicates an expected call of Record

type MockImportKVClient 

type MockImportKVClient struct {
	// contains filtered or unexported fields
}

MockImportKVClient is a mock of ImportKVClient interface

func NewMockImportKVClient 

func NewMockImportKVClient(ctrl *gomock.Controller) *MockImportKVClient

NewMockImportKVClient creates a new mock instance

func (*MockImportKVClient) CleanupEngine 

func (m *MockImportKVClient) CleanupEngine(arg0 context.Context, arg1 *import_kvpb.CleanupEngineRequest, arg2 ...grpc.CallOption) (*import_kvpb.CleanupEngineResponse, error)

CleanupEngine mocks base method

func (*MockImportKVClient) CloseEngine 

func (m *MockImportKVClient) CloseEngine(arg0 context.Context, arg1 *import_kvpb.CloseEngineRequest, arg2 ...grpc.CallOption) (*import_kvpb.CloseEngineResponse, error)

CloseEngine mocks base method

func (*MockImportKVClient) CompactCluster 

func (m *MockImportKVClient) CompactCluster(arg0 context.Context, arg1 *import_kvpb.CompactClusterRequest, arg2 ...grpc.CallOption) (*import_kvpb.CompactClusterResponse, error)

CompactCluster mocks base method

func (*MockImportKVClient) EXPECT 

func (m *MockImportKVClient) EXPECT() *MockImportKVClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockImportKVClient) GetMetrics 

func (m *MockImportKVClient) GetMetrics(arg0 context.Context, arg1 *import_kvpb.GetMetricsRequest, arg2 ...grpc.CallOption) (*import_kvpb.GetMetricsResponse, error)

GetMetrics mocks base method

func (*MockImportKVClient) GetVersion 

func (m *MockImportKVClient) GetVersion(arg0 context.Context, arg1 *import_kvpb.GetVersionRequest, arg2 ...grpc.CallOption) (*import_kvpb.GetVersionResponse, error)

GetVersion mocks base method

func (*MockImportKVClient) ImportEngine 

func (m *MockImportKVClient) ImportEngine(arg0 context.Context, arg1 *import_kvpb.ImportEngineRequest, arg2 ...grpc.CallOption) (*import_kvpb.ImportEngineResponse, error)

ImportEngine mocks base method

func (*MockImportKVClient) OpenEngine 

func (m *MockImportKVClient) OpenEngine(arg0 context.Context, arg1 *import_kvpb.OpenEngineRequest, arg2 ...grpc.CallOption) (*import_kvpb.OpenEngineResponse, error)

OpenEngine mocks base method

func (*MockImportKVClient) SwitchMode 

func (m *MockImportKVClient) SwitchMode(arg0 context.Context, arg1 *import_kvpb.SwitchModeRequest, arg2 ...grpc.CallOption) (*import_kvpb.SwitchModeResponse, error)

SwitchMode mocks base method

func (*MockImportKVClient) WriteEngine 

func (m *MockImportKVClient) WriteEngine(arg0 context.Context, arg1 ...grpc.CallOption) (import_kvpb.ImportKV_WriteEngineClient, error)

WriteEngine mocks base method

func (*MockImportKVClient) WriteEngineV3 

func (m *MockImportKVClient) WriteEngineV3(arg0 context.Context, arg1 *import_kvpb.WriteEngineV3Request, arg2 ...grpc.CallOption) (*import_kvpb.WriteEngineResponse, error)

WriteEngineV3 mocks base method

type MockImportKVClientMockRecorder 

type MockImportKVClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockImportKVClientMockRecorder is the mock recorder for MockImportKVClient

func (*MockImportKVClientMockRecorder) CleanupEngine 

func (mr *MockImportKVClientMockRecorder) CleanupEngine(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CleanupEngine indicates an expected call of CleanupEngine

func (*MockImportKVClientMockRecorder) CloseEngine 

func (mr *MockImportKVClientMockRecorder) CloseEngine(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CloseEngine indicates an expected call of CloseEngine

func (*MockImportKVClientMockRecorder) CompactCluster 

func (mr *MockImportKVClientMockRecorder) CompactCluster(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CompactCluster indicates an expected call of CompactCluster

func (*MockImportKVClientMockRecorder) GetMetrics 

func (mr *MockImportKVClientMockRecorder) GetMetrics(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetMetrics indicates an expected call of GetMetrics

func (*MockImportKVClientMockRecorder) GetVersion 

func (mr *MockImportKVClientMockRecorder) GetVersion(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetVersion indicates an expected call of GetVersion

func (*MockImportKVClientMockRecorder) ImportEngine 

func (mr *MockImportKVClientMockRecorder) ImportEngine(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ImportEngine indicates an expected call of ImportEngine

func (*MockImportKVClientMockRecorder) OpenEngine 

func (mr *MockImportKVClientMockRecorder) OpenEngine(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

OpenEngine indicates an expected call of OpenEngine

func (*MockImportKVClientMockRecorder) SwitchMode 

func (mr *MockImportKVClientMockRecorder) SwitchMode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SwitchMode indicates an expected call of SwitchMode

func (*MockImportKVClientMockRecorder) WriteEngine 

func (mr *MockImportKVClientMockRecorder) WriteEngine(arg0 interface{}, arg1 ...interface{}) *gomock.Call

WriteEngine indicates an expected call of WriteEngine

func (*MockImportKVClientMockRecorder) WriteEngineV3 

func (mr *MockImportKVClientMockRecorder) WriteEngineV3(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

WriteEngineV3 indicates an expected call of WriteEngineV3

type MockImportKV_WriteEngineClient 

type MockImportKV_WriteEngineClient struct {
	// contains filtered or unexported fields
}

MockImportKV_WriteEngineClient is a mock of ImportKV_WriteEngineClient interface

func NewMockImportKV_WriteEngineClient 

func NewMockImportKV_WriteEngineClient(ctrl *gomock.Controller) *MockImportKV_WriteEngineClient

NewMockImportKV_WriteEngineClient creates a new mock instance

func (*MockImportKV_WriteEngineClient) CloseAndRecv 

func (m *MockImportKV_WriteEngineClient) CloseAndRecv() (*import_kvpb.WriteEngineResponse, error)

CloseAndRecv mocks base method

func (*MockImportKV_WriteEngineClient) CloseSend 

func (m *MockImportKV_WriteEngineClient) CloseSend() error

CloseSend mocks base method

func (*MockImportKV_WriteEngineClient) Context 

func (m *MockImportKV_WriteEngineClient) Context() context.Context

Context mocks base method

func (*MockImportKV_WriteEngineClient) EXPECT 

func (m *MockImportKV_WriteEngineClient) EXPECT() *MockImportKV_WriteEngineClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockImportKV_WriteEngineClient) Header 

func (m *MockImportKV_WriteEngineClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockImportKV_WriteEngineClient) RecvMsg 

func (m *MockImportKV_WriteEngineClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method

func (*MockImportKV_WriteEngineClient) Send 

func (m *MockImportKV_WriteEngineClient) Send(arg0 *import_kvpb.WriteEngineRequest) error

Send mocks base method

func (*MockImportKV_WriteEngineClient) SendMsg 

func (m *MockImportKV_WriteEngineClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method

func (*MockImportKV_WriteEngineClient) Trailer 

func (m *MockImportKV_WriteEngineClient) Trailer() metadata.MD

Trailer mocks base method

type MockImportKV_WriteEngineClientMockRecorder 

type MockImportKV_WriteEngineClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockImportKV_WriteEngineClientMockRecorder is the mock recorder for MockImportKV_WriteEngineClient

func (*MockImportKV_WriteEngineClientMockRecorder) CloseAndRecv 

func (mr *MockImportKV_WriteEngineClientMockRecorder) CloseAndRecv() *gomock.Call

CloseAndRecv indicates an expected call of CloseAndRecv

func (*MockImportKV_WriteEngineClientMockRecorder) CloseSend 

func (mr *MockImportKV_WriteEngineClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockImportKV_WriteEngineClientMockRecorder) Context 

func (mr *MockImportKV_WriteEngineClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockImportKV_WriteEngineClientMockRecorder) Header 

func (mr *MockImportKV_WriteEngineClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockImportKV_WriteEngineClientMockRecorder) RecvMsg 

func (mr *MockImportKV_WriteEngineClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockImportKV_WriteEngineClientMockRecorder) Send 

func (mr *MockImportKV_WriteEngineClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockImportKV_WriteEngineClientMockRecorder) SendMsg 

func (mr *MockImportKV_WriteEngineClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockImportKV_WriteEngineClientMockRecorder) Trailer 

func (mr *MockImportKV_WriteEngineClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockRow 

type MockRow struct {
	// contains filtered or unexported fields
}

MockRow is a mock of Row interface

func NewMockRow 

func NewMockRow(ctrl *gomock.Controller) *MockRow

NewMockRow creates a new mock instance

func (*MockRow) ClassifyAndAppend 

func (m *MockRow) ClassifyAndAppend(arg0 *backend.Rows, arg1 *verification.KVChecksum, arg2 *backend.Rows, arg3 *verification.KVChecksum)

ClassifyAndAppend mocks base method

func (*MockRow) EXPECT 

func (m *MockRow) EXPECT() *MockRowMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

type MockRowMockRecorder 

type MockRowMockRecorder struct {
	// contains filtered or unexported fields
}

MockRowMockRecorder is the mock recorder for MockRow

func (*MockRowMockRecorder) ClassifyAndAppend 

func (mr *MockRowMockRecorder) ClassifyAndAppend(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

ClassifyAndAppend indicates an expected call of ClassifyAndAppend

type MockRows 

type MockRows struct {
	// contains filtered or unexported fields
}

MockRows is a mock of Rows interface

func NewMockRows 

func NewMockRows(ctrl *gomock.Controller) *MockRows

NewMockRows creates a new mock instance

func (*MockRows) Clear 

func (m *MockRows) Clear() backend.Rows

Clear mocks base method

func (*MockRows) EXPECT 

func (m *MockRows) EXPECT() *MockRowsMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockRows) SplitIntoChunks 

func (m *MockRows) SplitIntoChunks(arg0 int) []backend.Rows

SplitIntoChunks mocks base method

type MockRowsMockRecorder 

type MockRowsMockRecorder struct {
	// contains filtered or unexported fields
}

MockRowsMockRecorder is the mock recorder for MockRows

func (*MockRowsMockRecorder) Clear 

func (mr *MockRowsMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear

func (*MockRowsMockRecorder) SplitIntoChunks 

func (mr *MockRowsMockRecorder) SplitIntoChunks(arg0 interface{}) *gomock.Call

SplitIntoChunks indicates an expected call of SplitIntoChunks

type MockSQLExecutor 

type MockSQLExecutor struct {
	// contains filtered or unexported fields
}

MockSQLExecutor is a mock of SQLExecutor interface

func NewMockSQLExecutor 

func NewMockSQLExecutor(ctrl *gomock.Controller) *MockSQLExecutor

NewMockSQLExecutor creates a new mock instance

func (*MockSQLExecutor) Close 

func (m *MockSQLExecutor) Close()

Close mocks base method

func (*MockSQLExecutor) EXPECT 

func (m *MockSQLExecutor) EXPECT() *MockSQLExecutorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSQLExecutor) ExecuteWithLog 

func (m *MockSQLExecutor) ExecuteWithLog(ctx context.Context, query, purpose string, logger log.Logger) error

ExecuteWithLog mocks base method

func (*MockSQLExecutor) ObtainStringWithLog 

func (m *MockSQLExecutor) ObtainStringWithLog(ctx context.Context, query, purpose string, logger log.Logger) (string, error)

ObtainStringWithLog mocks base method

func (*MockSQLExecutor) QueryStringsWithLog 

func (m *MockSQLExecutor) QueryStringsWithLog(ctx context.Context, query, purpose string, logger log.Logger) ([][]string, error)

QueryStringsWithLog mocks base method

type MockSQLExecutorMockRecorder 

type MockSQLExecutorMockRecorder struct {
	// contains filtered or unexported fields
}

MockSQLExecutorMockRecorder is the mock recorder for MockSQLExecutor

func (*MockSQLExecutorMockRecorder) Close 

func (mr *MockSQLExecutorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSQLExecutorMockRecorder) ExecuteWithLog 

func (mr *MockSQLExecutorMockRecorder) ExecuteWithLog(ctx, query, purpose, logger interface{}) *gomock.Call

ExecuteWithLog indicates an expected call of ExecuteWithLog

func (*MockSQLExecutorMockRecorder) ObtainStringWithLog 

func (mr *MockSQLExecutorMockRecorder) ObtainStringWithLog(ctx, query, purpose, logger interface{}) *gomock.Call

ObtainStringWithLog indicates an expected call of ObtainStringWithLog

func (*MockSQLExecutorMockRecorder) QueryStringsWithLog 

func (mr *MockSQLExecutorMockRecorder) QueryStringsWithLog(ctx, query, purpose, logger interface{}) *gomock.Call

QueryStringsWithLog indicates an expected call of QueryStringsWithLog

type MockSession 

type MockSession struct {
	// contains filtered or unexported fields
}

MockSession is a mock of Session interface

func NewMockSession 

func NewMockSession(ctrl *gomock.Controller) *MockSession

NewMockSession creates a new mock instance

func (*MockSession) Close 

func (m *MockSession) Close()

Close mocks base method

func (*MockSession) CommitTxn 

func (m *MockSession) CommitTxn(arg0 context.Context) error

CommitTxn mocks base method

func (*MockSession) DropPreparedStmt 

func (m *MockSession) DropPreparedStmt(stmtID uint32) error

DropPreparedStmt mocks base method

func (*MockSession) EXPECT 

func (m *MockSession) EXPECT() *MockSessionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockSession) Execute 

func (m *MockSession) Execute(arg0 context.Context, arg1 string) ([]sqlexec.RecordSet, error)

Execute mocks base method

func (*MockSession) ExecutePreparedStmt 

func (m *MockSession) ExecutePreparedStmt(ctx context.Context, stmtID uint32, param []types.Datum) (sqlexec.RecordSet, error)

ExecutePreparedStmt mocks base method

func (*MockSession) PrepareStmt 

func (m *MockSession) PrepareStmt(sql string) (uint32, int, []*ast.ResultField, error)

PrepareStmt mocks base method

func (*MockSession) RollbackTxn 

func (m *MockSession) RollbackTxn(arg0 context.Context)

RollbackTxn mocks base method

type MockSessionMockRecorder 

type MockSessionMockRecorder struct {
	// contains filtered or unexported fields
}

MockSessionMockRecorder is the mock recorder for MockSession

func (*MockSessionMockRecorder) Close 

func (mr *MockSessionMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockSessionMockRecorder) CommitTxn 

func (mr *MockSessionMockRecorder) CommitTxn(arg0 interface{}) *gomock.Call

CommitTxn indicates an expected call of CommitTxn

func (*MockSessionMockRecorder) DropPreparedStmt 

func (mr *MockSessionMockRecorder) DropPreparedStmt(stmtID interface{}) *gomock.Call

DropPreparedStmt indicates an expected call of DropPreparedStmt

func (*MockSessionMockRecorder) Execute 

func (mr *MockSessionMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call

Execute indicates an expected call of Execute

func (*MockSessionMockRecorder) ExecutePreparedStmt 

func (mr *MockSessionMockRecorder) ExecutePreparedStmt(ctx, stmtID, param interface{}) *gomock.Call

ExecutePreparedStmt indicates an expected call of ExecutePreparedStmt

func (*MockSessionMockRecorder) PrepareStmt 

func (mr *MockSessionMockRecorder) PrepareStmt(sql interface{}) *gomock.Call

PrepareStmt indicates an expected call of PrepareStmt

func (*MockSessionMockRecorder) RollbackTxn 

func (mr *MockSessionMockRecorder) RollbackTxn(arg0 interface{}) *gomock.Call

RollbackTxn indicates an expected call of RollbackTxn

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.