mock

package
v4.0.10+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2021 License: Apache-2.0 Imports: 15 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.

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

func (m *MockBackend) LocalWriter(arg0 context.Context, arg1 uuid.UUID) (backend.EngineWriter, error)

LocalWriter mocks base method

func (*MockBackend) MakeEmptyRows 

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

MakeEmptyRows 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

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

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

LocalWriter indicates an expected call of LocalWriter

func (*MockBackendMockRecorder) MakeEmptyRows 

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

MakeEmptyRows indicates an expected call of MakeEmptyRows

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

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 MockEngineWriter 

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

MockEngineWriter is a mock of EngineWriter interface

func NewMockEngineWriter 

func NewMockEngineWriter(ctrl *gomock.Controller) *MockEngineWriter

NewMockEngineWriter creates a new mock instance

func (*MockEngineWriter) AppendRows 

func (m *MockEngineWriter) AppendRows(arg0 context.Context, arg1 string, arg2 []string, arg3 uint64, arg4 backend.Rows) error

AppendRows mocks base method

func (*MockEngineWriter) Close 

func (m *MockEngineWriter) Close() error

Close mocks base method

func (*MockEngineWriter) EXPECT 

func (m *MockEngineWriter) EXPECT() *MockEngineWriterMockRecorder

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

type MockEngineWriterMockRecorder 

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

MockEngineWriterMockRecorder is the mock recorder for MockEngineWriter

func (*MockEngineWriterMockRecorder) AppendRows 

func (mr *MockEngineWriterMockRecorder) AppendRows(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

AppendRows indicates an expected call of AppendRows

func (*MockEngineWriterMockRecorder) Close 

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

Close indicates an expected call of Close

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

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.