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 ¶
- type Cluster
- type MockBackend
- func (m *MockBackend) CleanupEngine(arg0 context.Context, arg1 uuid.UUID) error
- func (m *MockBackend) Close()
- func (m *MockBackend) CloseEngine(arg0 context.Context, arg1 *backend.EngineConfig, arg2 uuid.UUID) error
- func (m *MockBackend) EXPECT() *MockBackendMockRecorder
- func (m *MockBackend) FlushAllEngines(arg0 context.Context) error
- func (m *MockBackend) FlushEngine(arg0 context.Context, arg1 uuid.UUID) error
- func (m *MockBackend) ISGOMOCK() struct{}
- func (m *MockBackend) ImportEngine(arg0 context.Context, arg1 uuid.UUID, arg2, arg3 int64) error
- func (m *MockBackend) LocalWriter(arg0 context.Context, arg1 *backend.LocalWriterConfig, arg2 uuid.UUID) (backend.EngineWriter, error)
- func (m *MockBackend) OpenEngine(arg0 context.Context, arg1 *backend.EngineConfig, arg2 uuid.UUID) error
- func (m *MockBackend) RetryImportDelay() time.Duration
- func (m *MockBackend) ShouldPostProcess() bool
- type MockBackendMockRecorder
- func (mr *MockBackendMockRecorder) CleanupEngine(arg0, arg1 any) *gomock.Call
- func (mr *MockBackendMockRecorder) Close() *gomock.Call
- func (mr *MockBackendMockRecorder) CloseEngine(arg0, arg1, arg2 any) *gomock.Call
- func (mr *MockBackendMockRecorder) FlushAllEngines(arg0 any) *gomock.Call
- func (mr *MockBackendMockRecorder) FlushEngine(arg0, arg1 any) *gomock.Call
- func (mr *MockBackendMockRecorder) ImportEngine(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockBackendMockRecorder) LocalWriter(arg0, arg1, arg2 any) *gomock.Call
- func (mr *MockBackendMockRecorder) OpenEngine(arg0, arg1, arg2 any) *gomock.Call
- func (mr *MockBackendMockRecorder) RetryImportDelay() *gomock.Call
- func (mr *MockBackendMockRecorder) ShouldPostProcess() *gomock.Call
- type MockChunkFlushStatus
- type MockChunkFlushStatusMockRecorder
- type MockEncoder
- type MockEncoderMockRecorder
- type MockEncodingBuilder
- type MockEncodingBuilderMockRecorder
- type MockEngineWriter
- func (m *MockEngineWriter) AppendRows(arg0 context.Context, arg1 []string, arg2 encode.Rows) error
- func (m *MockEngineWriter) Close(arg0 context.Context) (common.ChunkFlushStatus, error)
- func (m *MockEngineWriter) EXPECT() *MockEngineWriterMockRecorder
- func (m *MockEngineWriter) ISGOMOCK() struct{}
- func (m *MockEngineWriter) IsSynced() bool
- type MockEngineWriterMockRecorder
- type MockImportKVClient
- func (m *MockImportKVClient) CleanupEngine(arg0 context.Context, arg1 *import_kvpb.CleanupEngineRequest, ...) (*import_kvpb.CleanupEngineResponse, error)
- func (m *MockImportKVClient) CloseEngine(arg0 context.Context, arg1 *import_kvpb.CloseEngineRequest, ...) (*import_kvpb.CloseEngineResponse, error)
- func (m *MockImportKVClient) CompactCluster(arg0 context.Context, arg1 *import_kvpb.CompactClusterRequest, ...) (*import_kvpb.CompactClusterResponse, error)
- func (m *MockImportKVClient) EXPECT() *MockImportKVClientMockRecorder
- func (m *MockImportKVClient) GetMetrics(arg0 context.Context, arg1 *import_kvpb.GetMetricsRequest, ...) (*import_kvpb.GetMetricsResponse, error)
- func (m *MockImportKVClient) GetVersion(arg0 context.Context, arg1 *import_kvpb.GetVersionRequest, ...) (*import_kvpb.GetVersionResponse, error)
- func (m *MockImportKVClient) ImportEngine(arg0 context.Context, arg1 *import_kvpb.ImportEngineRequest, ...) (*import_kvpb.ImportEngineResponse, error)
- func (m *MockImportKVClient) OpenEngine(arg0 context.Context, arg1 *import_kvpb.OpenEngineRequest, ...) (*import_kvpb.OpenEngineResponse, error)
- func (m *MockImportKVClient) SwitchMode(arg0 context.Context, arg1 *import_kvpb.SwitchModeRequest, ...) (*import_kvpb.SwitchModeResponse, error)
- func (m *MockImportKVClient) WriteEngine(arg0 context.Context, arg1 ...grpc.CallOption) (import_kvpb.ImportKV_WriteEngineClient, error)
- func (m *MockImportKVClient) WriteEngineV3(arg0 context.Context, arg1 *import_kvpb.WriteEngineV3Request, ...) (*import_kvpb.WriteEngineResponse, error)
- type MockImportKVClientMockRecorder
- func (mr *MockImportKVClientMockRecorder) CleanupEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) CloseEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) CompactCluster(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) GetMetrics(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) GetVersion(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) ImportEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) OpenEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) SwitchMode(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) WriteEngine(arg0 any, arg1 ...any) *gomock.Call
- func (mr *MockImportKVClientMockRecorder) WriteEngineV3(arg0, arg1 any, arg2 ...any) *gomock.Call
- type MockImportKV_WriteEngineClient
- func (m *MockImportKV_WriteEngineClient) CloseAndRecv() (*import_kvpb.WriteEngineResponse, error)
- func (m *MockImportKV_WriteEngineClient) CloseSend() error
- func (m *MockImportKV_WriteEngineClient) Context() context.Context
- func (m *MockImportKV_WriteEngineClient) EXPECT() *MockImportKV_WriteEngineClientMockRecorder
- func (m *MockImportKV_WriteEngineClient) Header() (metadata.MD, error)
- func (m *MockImportKV_WriteEngineClient) RecvMsg(arg0 any) error
- func (m *MockImportKV_WriteEngineClient) Send(arg0 *import_kvpb.WriteEngineRequest) error
- func (m *MockImportKV_WriteEngineClient) SendMsg(arg0 any) error
- func (m *MockImportKV_WriteEngineClient) Trailer() metadata.MD
- type MockImportKV_WriteEngineClientMockRecorder
- func (mr *MockImportKV_WriteEngineClientMockRecorder) CloseAndRecv() *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) Context() *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) Header() *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) RecvMsg(arg0 any) *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) SendMsg(arg0 any) *gomock.Call
- func (mr *MockImportKV_WriteEngineClientMockRecorder) Trailer() *gomock.Call
- type MockRow
- type MockRowMockRecorder
- type MockRows
- type MockRowsMockRecorder
- type MockTargetInfoGetter
- func (m *MockTargetInfoGetter) CheckRequirements(arg0 context.Context, arg1 *backend.CheckCtx) error
- func (m *MockTargetInfoGetter) EXPECT() *MockTargetInfoGetterMockRecorder
- func (m *MockTargetInfoGetter) FetchRemoteDBModels(arg0 context.Context) ([]*model.DBInfo, error)
- func (m *MockTargetInfoGetter) FetchRemoteTableModels(arg0 context.Context, arg1 string, arg2 []string) (map[string]*model.TableInfo, error)
- func (m *MockTargetInfoGetter) ISGOMOCK() struct{}
- type MockTargetInfoGetterMockRecorder
- type MockTaskRegister
- func (m *MockTaskRegister) Close(arg0 context.Context) error
- func (m *MockTaskRegister) EXPECT() *MockTaskRegisterMockRecorder
- func (m *MockTaskRegister) ISGOMOCK() struct{}
- func (m *MockTaskRegister) RegisterTask(arg0 context.Context) error
- func (m *MockTaskRegister) RegisterTaskOnce(arg0 context.Context) error
- type MockTaskRegisterMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
type Cluster struct {
*server.Server
testutils.Cluster
kv.Storage
*server.TiDBDriver
*domain.Domain
DSN string
PDClient pd.Client
PDHTTPCli pdhttp.Client
HttpServer *http.Server
}
Cluster is mock tidb cluster, includes tikv and pd.
type MockBackend ¶
type MockBackend struct {
// contains filtered or unexported fields
}
MockBackend is a mock of Backend interface.
func NewMockBackend ¶
func NewMockBackend(ctrl *gomock.Controller) *MockBackend
NewMockBackend creates a new mock instance.
func (*MockBackend) CleanupEngine ¶
CleanupEngine mocks base method.
func (*MockBackend) CloseEngine ¶
func (m *MockBackend) CloseEngine(arg0 context.Context, arg1 *backend.EngineConfig, arg2 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) FlushAllEngines ¶
func (m *MockBackend) FlushAllEngines(arg0 context.Context) error
FlushAllEngines mocks base method.
func (*MockBackend) FlushEngine ¶
FlushEngine mocks base method.
func (*MockBackend) ISGOMOCK ¶
func (m *MockBackend) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
func (*MockBackend) ImportEngine ¶
ImportEngine mocks base method.
func (*MockBackend) LocalWriter ¶
func (m *MockBackend) LocalWriter(arg0 context.Context, arg1 *backend.LocalWriterConfig, arg2 uuid.UUID) (backend.EngineWriter, error)
LocalWriter mocks base method.
func (*MockBackend) OpenEngine ¶
func (m *MockBackend) OpenEngine(arg0 context.Context, arg1 *backend.EngineConfig, arg2 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) CleanupEngine ¶
func (mr *MockBackendMockRecorder) CleanupEngine(arg0, arg1 any) *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, arg2 any) *gomock.Call
CloseEngine indicates an expected call of CloseEngine.
func (*MockBackendMockRecorder) FlushAllEngines ¶
func (mr *MockBackendMockRecorder) FlushAllEngines(arg0 any) *gomock.Call
FlushAllEngines indicates an expected call of FlushAllEngines.
func (*MockBackendMockRecorder) FlushEngine ¶
func (mr *MockBackendMockRecorder) FlushEngine(arg0, arg1 any) *gomock.Call
FlushEngine indicates an expected call of FlushEngine.
func (*MockBackendMockRecorder) ImportEngine ¶
func (mr *MockBackendMockRecorder) ImportEngine(arg0, arg1, arg2, arg3 any) *gomock.Call
ImportEngine indicates an expected call of ImportEngine.
func (*MockBackendMockRecorder) LocalWriter ¶
func (mr *MockBackendMockRecorder) LocalWriter(arg0, arg1, arg2 any) *gomock.Call
LocalWriter indicates an expected call of LocalWriter.
func (*MockBackendMockRecorder) OpenEngine ¶
func (mr *MockBackendMockRecorder) OpenEngine(arg0, arg1, arg2 any) *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 MockChunkFlushStatus ¶
type MockChunkFlushStatus struct {
// contains filtered or unexported fields
}
MockChunkFlushStatus is a mock of ChunkFlushStatus interface.
func NewMockChunkFlushStatus ¶
func NewMockChunkFlushStatus(ctrl *gomock.Controller) *MockChunkFlushStatus
NewMockChunkFlushStatus creates a new mock instance.
func (*MockChunkFlushStatus) EXPECT ¶
func (m *MockChunkFlushStatus) EXPECT() *MockChunkFlushStatusMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockChunkFlushStatus) Flushed ¶
func (m *MockChunkFlushStatus) Flushed() bool
Flushed mocks base method.
func (*MockChunkFlushStatus) ISGOMOCK ¶
func (m *MockChunkFlushStatus) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
type MockChunkFlushStatusMockRecorder ¶
type MockChunkFlushStatusMockRecorder struct {
// contains filtered or unexported fields
}
MockChunkFlushStatusMockRecorder is the mock recorder for MockChunkFlushStatus.
func (*MockChunkFlushStatusMockRecorder) Flushed ¶
func (mr *MockChunkFlushStatusMockRecorder) Flushed() *gomock.Call
Flushed indicates an expected call of Flushed.
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) 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 []types.Datum, arg1 int64, arg2 []int, arg3 int64) (encode.Row, error)
Encode mocks base method.
func (*MockEncoder) ISGOMOCK ¶
func (m *MockEncoder) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
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.
type MockEncodingBuilder ¶
type MockEncodingBuilder struct {
// contains filtered or unexported fields
}
MockEncodingBuilder is a mock of EncodingBuilder interface.
func NewMockEncodingBuilder ¶
func NewMockEncodingBuilder(ctrl *gomock.Controller) *MockEncodingBuilder
NewMockEncodingBuilder creates a new mock instance.
func (*MockEncodingBuilder) EXPECT ¶
func (m *MockEncodingBuilder) EXPECT() *MockEncodingBuilderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEncodingBuilder) ISGOMOCK ¶
func (m *MockEncodingBuilder) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
func (*MockEncodingBuilder) MakeEmptyRows ¶
func (m *MockEncodingBuilder) MakeEmptyRows() encode.Rows
MakeEmptyRows mocks base method.
func (*MockEncodingBuilder) NewEncoder ¶
func (m *MockEncodingBuilder) NewEncoder(arg0 context.Context, arg1 *encode.EncodingConfig) (encode.Encoder, error)
NewEncoder mocks base method.
type MockEncodingBuilderMockRecorder ¶
type MockEncodingBuilderMockRecorder struct {
// contains filtered or unexported fields
}
MockEncodingBuilderMockRecorder is the mock recorder for MockEncodingBuilder.
func (*MockEncodingBuilderMockRecorder) MakeEmptyRows ¶
func (mr *MockEncodingBuilderMockRecorder) MakeEmptyRows() *gomock.Call
MakeEmptyRows indicates an expected call of MakeEmptyRows.
func (*MockEncodingBuilderMockRecorder) NewEncoder ¶
func (mr *MockEncodingBuilderMockRecorder) NewEncoder(arg0, arg1 any) *gomock.Call
NewEncoder indicates an expected call of NewEncoder.
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 ¶
AppendRows mocks base method.
func (*MockEngineWriter) Close ¶
func (m *MockEngineWriter) Close(arg0 context.Context) (common.ChunkFlushStatus, 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.
func (*MockEngineWriter) ISGOMOCK ¶
func (m *MockEngineWriter) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
func (*MockEngineWriter) IsSynced ¶
func (m *MockEngineWriter) IsSynced() bool
IsSynced mocks base method.
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 any) *gomock.Call
AppendRows indicates an expected call of AppendRows.
func (*MockEngineWriterMockRecorder) Close ¶
func (mr *MockEngineWriterMockRecorder) Close(arg0 any) *gomock.Call
Close indicates an expected call of Close.
func (*MockEngineWriterMockRecorder) IsSynced ¶
func (mr *MockEngineWriterMockRecorder) IsSynced() *gomock.Call
IsSynced indicates an expected call of IsSynced.
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 any, arg2 ...any) *gomock.Call
CleanupEngine indicates an expected call of CleanupEngine
func (*MockImportKVClientMockRecorder) CloseEngine ¶
func (mr *MockImportKVClientMockRecorder) CloseEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
CloseEngine indicates an expected call of CloseEngine
func (*MockImportKVClientMockRecorder) CompactCluster ¶
func (mr *MockImportKVClientMockRecorder) CompactCluster(arg0, arg1 any, arg2 ...any) *gomock.Call
CompactCluster indicates an expected call of CompactCluster
func (*MockImportKVClientMockRecorder) GetMetrics ¶
func (mr *MockImportKVClientMockRecorder) GetMetrics(arg0, arg1 any, arg2 ...any) *gomock.Call
GetMetrics indicates an expected call of GetMetrics
func (*MockImportKVClientMockRecorder) GetVersion ¶
func (mr *MockImportKVClientMockRecorder) GetVersion(arg0, arg1 any, arg2 ...any) *gomock.Call
GetVersion indicates an expected call of GetVersion
func (*MockImportKVClientMockRecorder) ImportEngine ¶
func (mr *MockImportKVClientMockRecorder) ImportEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
ImportEngine indicates an expected call of ImportEngine
func (*MockImportKVClientMockRecorder) OpenEngine ¶
func (mr *MockImportKVClientMockRecorder) OpenEngine(arg0, arg1 any, arg2 ...any) *gomock.Call
OpenEngine indicates an expected call of OpenEngine
func (*MockImportKVClientMockRecorder) SwitchMode ¶
func (mr *MockImportKVClientMockRecorder) SwitchMode(arg0, arg1 any, arg2 ...any) *gomock.Call
SwitchMode indicates an expected call of SwitchMode
func (*MockImportKVClientMockRecorder) WriteEngine ¶
func (mr *MockImportKVClientMockRecorder) WriteEngine(arg0 any, arg1 ...any) *gomock.Call
WriteEngine indicates an expected call of WriteEngine
func (*MockImportKVClientMockRecorder) WriteEngineV3 ¶
func (mr *MockImportKVClientMockRecorder) WriteEngineV3(arg0, arg1 any, arg2 ...any) *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 any) 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 any) 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 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockImportKV_WriteEngineClientMockRecorder) Send ¶
func (mr *MockImportKV_WriteEngineClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send
func (*MockImportKV_WriteEngineClientMockRecorder) SendMsg ¶
func (mr *MockImportKV_WriteEngineClientMockRecorder) SendMsg(arg0 any) *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 *encode.Rows, arg1 *verification.KVChecksum, arg2 *encode.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 any) *gomock.Call
ClassifyAndAppend indicates an expected call of ClassifyAndAppend.
func (*MockRowMockRecorder) Size ¶
func (mr *MockRowMockRecorder) Size() *gomock.Call
Size indicates an expected call of Size.
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) EXPECT ¶
func (m *MockRows) EXPECT() *MockRowsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
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.
type MockTargetInfoGetter ¶
type MockTargetInfoGetter struct {
// contains filtered or unexported fields
}
MockTargetInfoGetter is a mock of TargetInfoGetter interface.
func NewMockTargetInfoGetter ¶
func NewMockTargetInfoGetter(ctrl *gomock.Controller) *MockTargetInfoGetter
NewMockTargetInfoGetter creates a new mock instance.
func (*MockTargetInfoGetter) CheckRequirements ¶
func (m *MockTargetInfoGetter) CheckRequirements(arg0 context.Context, arg1 *backend.CheckCtx) error
CheckRequirements mocks base method.
func (*MockTargetInfoGetter) EXPECT ¶
func (m *MockTargetInfoGetter) EXPECT() *MockTargetInfoGetterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTargetInfoGetter) FetchRemoteDBModels ¶
FetchRemoteDBModels mocks base method.
func (*MockTargetInfoGetter) FetchRemoteTableModels ¶
func (m *MockTargetInfoGetter) FetchRemoteTableModels(arg0 context.Context, arg1 string, arg2 []string) (map[string]*model.TableInfo, error)
FetchRemoteTableModels mocks base method.
func (*MockTargetInfoGetter) ISGOMOCK ¶
func (m *MockTargetInfoGetter) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
type MockTargetInfoGetterMockRecorder ¶
type MockTargetInfoGetterMockRecorder struct {
// contains filtered or unexported fields
}
MockTargetInfoGetterMockRecorder is the mock recorder for MockTargetInfoGetter.
func (*MockTargetInfoGetterMockRecorder) CheckRequirements ¶
func (mr *MockTargetInfoGetterMockRecorder) CheckRequirements(arg0, arg1 any) *gomock.Call
CheckRequirements indicates an expected call of CheckRequirements.
func (*MockTargetInfoGetterMockRecorder) FetchRemoteDBModels ¶
func (mr *MockTargetInfoGetterMockRecorder) FetchRemoteDBModels(arg0 any) *gomock.Call
FetchRemoteDBModels indicates an expected call of FetchRemoteDBModels.
func (*MockTargetInfoGetterMockRecorder) FetchRemoteTableModels ¶
func (mr *MockTargetInfoGetterMockRecorder) FetchRemoteTableModels(arg0, arg1, arg2 any) *gomock.Call
FetchRemoteTableModels indicates an expected call of FetchRemoteTableModels.
type MockTaskRegister ¶
type MockTaskRegister struct {
// contains filtered or unexported fields
}
MockTaskRegister is a mock of TaskRegister interface.
func NewMockTaskRegister ¶
func NewMockTaskRegister(ctrl *gomock.Controller) *MockTaskRegister
NewMockTaskRegister creates a new mock instance.
func (*MockTaskRegister) Close ¶
func (m *MockTaskRegister) Close(arg0 context.Context) error
Close mocks base method.
func (*MockTaskRegister) EXPECT ¶
func (m *MockTaskRegister) EXPECT() *MockTaskRegisterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaskRegister) ISGOMOCK ¶
func (m *MockTaskRegister) ISGOMOCK() struct{}
ISGOMOCK indicates that this struct is a gomock mock.
func (*MockTaskRegister) RegisterTask ¶
func (m *MockTaskRegister) RegisterTask(arg0 context.Context) error
RegisterTask mocks base method.
func (*MockTaskRegister) RegisterTaskOnce ¶
func (m *MockTaskRegister) RegisterTaskOnce(arg0 context.Context) error
RegisterTaskOnce mocks base method.
type MockTaskRegisterMockRecorder ¶
type MockTaskRegisterMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskRegisterMockRecorder is the mock recorder for MockTaskRegister.
func (*MockTaskRegisterMockRecorder) Close ¶
func (mr *MockTaskRegisterMockRecorder) Close(arg0 any) *gomock.Call
Close indicates an expected call of Close.
func (*MockTaskRegisterMockRecorder) RegisterTask ¶
func (mr *MockTaskRegisterMockRecorder) RegisterTask(arg0 any) *gomock.Call
RegisterTask indicates an expected call of RegisterTask.
func (*MockTaskRegisterMockRecorder) RegisterTaskOnce ¶
func (mr *MockTaskRegisterMockRecorder) RegisterTaskOnce(arg0 any) *gomock.Call
RegisterTaskOnce indicates an expected call of RegisterTaskOnce.