pbmock

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package pbmock is a generated GoMock package.

Package pbmock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockMasterClient 

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

MockMasterClient is a mock of MasterClient interface

func NewMockMasterClient 

func NewMockMasterClient(ctrl *gomock.Controller) *MockMasterClient

NewMockMasterClient creates a new mock instance

func (*MockMasterClient) BreakWorkerDDLLock 

func (m *MockMasterClient) BreakWorkerDDLLock(arg0 context.Context, arg1 *pb.BreakWorkerDDLLockRequest, arg2 ...grpc.CallOption) (*pb.BreakWorkerDDLLockResponse, error)

BreakWorkerDDLLock mocks base method

func (*MockMasterClient) CheckTask 

func (m *MockMasterClient) CheckTask(arg0 context.Context, arg1 *pb.CheckTaskRequest, arg2 ...grpc.CallOption) (*pb.CheckTaskResponse, error)

CheckTask mocks base method

func (*MockMasterClient) EXPECT 

func (m *MockMasterClient) EXPECT() *MockMasterClientMockRecorder

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

func (*MockMasterClient) HandleSQLs 

func (m *MockMasterClient) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSQLsRequest, arg2 ...grpc.CallOption) (*pb.HandleSQLsResponse, error)

HandleSQLs mocks base method

func (*MockMasterClient) MigrateWorkerRelay 

func (m *MockMasterClient) MigrateWorkerRelay(arg0 context.Context, arg1 *pb.MigrateWorkerRelayRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

MigrateWorkerRelay mocks base method

func (*MockMasterClient) OperateTask 

func (m *MockMasterClient) OperateTask(arg0 context.Context, arg1 *pb.OperateTaskRequest, arg2 ...grpc.CallOption) (*pb.OperateTaskResponse, error)

OperateTask mocks base method

func (*MockMasterClient) OperateWorkerRelayTask 

func (m *MockMasterClient) OperateWorkerRelayTask(arg0 context.Context, arg1 *pb.OperateWorkerRelayRequest, arg2 ...grpc.CallOption) (*pb.OperateWorkerRelayResponse, error)

OperateWorkerRelayTask mocks base method

func (*MockMasterClient) PurgeWorkerRelay 

func (m *MockMasterClient) PurgeWorkerRelay(arg0 context.Context, arg1 *pb.PurgeWorkerRelayRequest, arg2 ...grpc.CallOption) (*pb.PurgeWorkerRelayResponse, error)

PurgeWorkerRelay mocks base method

func (*MockMasterClient) QueryError 

func (m *MockMasterClient) QueryError(arg0 context.Context, arg1 *pb.QueryErrorListRequest, arg2 ...grpc.CallOption) (*pb.QueryErrorListResponse, error)

QueryError mocks base method

func (*MockMasterClient) QueryStatus 

func (m *MockMasterClient) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusListRequest, arg2 ...grpc.CallOption) (*pb.QueryStatusListResponse, error)

QueryStatus mocks base method

func (*MockMasterClient) RefreshWorkerTasks 

func (m *MockMasterClient) RefreshWorkerTasks(arg0 context.Context, arg1 *pb.RefreshWorkerTasksRequest, arg2 ...grpc.CallOption) (*pb.RefreshWorkerTasksResponse, error)

RefreshWorkerTasks mocks base method

func (*MockMasterClient) ShowDDLLocks 

func (m *MockMasterClient) ShowDDLLocks(arg0 context.Context, arg1 *pb.ShowDDLLocksRequest, arg2 ...grpc.CallOption) (*pb.ShowDDLLocksResponse, error)

ShowDDLLocks mocks base method

func (*MockMasterClient) StartTask 

func (m *MockMasterClient) StartTask(arg0 context.Context, arg1 *pb.StartTaskRequest, arg2 ...grpc.CallOption) (*pb.StartTaskResponse, error)

StartTask mocks base method

func (*MockMasterClient) SwitchWorkerRelayMaster 

func (m *MockMasterClient) SwitchWorkerRelayMaster(arg0 context.Context, arg1 *pb.SwitchWorkerRelayMasterRequest, arg2 ...grpc.CallOption) (*pb.SwitchWorkerRelayMasterResponse, error)

SwitchWorkerRelayMaster mocks base method

func (*MockMasterClient) UnlockDDLLock 

func (m *MockMasterClient) UnlockDDLLock(arg0 context.Context, arg1 *pb.UnlockDDLLockRequest, arg2 ...grpc.CallOption) (*pb.UnlockDDLLockResponse, error)

UnlockDDLLock mocks base method

func (*MockMasterClient) UpdateMasterConfig 

func (m *MockMasterClient) UpdateMasterConfig(arg0 context.Context, arg1 *pb.UpdateMasterConfigRequest, arg2 ...grpc.CallOption) (*pb.UpdateMasterConfigResponse, error)

UpdateMasterConfig mocks base method

func (*MockMasterClient) UpdateTask 

func (m *MockMasterClient) UpdateTask(arg0 context.Context, arg1 *pb.UpdateTaskRequest, arg2 ...grpc.CallOption) (*pb.UpdateTaskResponse, error)

UpdateTask mocks base method

func (*MockMasterClient) UpdateWorkerRelayConfig 

func (m *MockMasterClient) UpdateWorkerRelayConfig(arg0 context.Context, arg1 *pb.UpdateWorkerRelayConfigRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

UpdateWorkerRelayConfig mocks base method

type MockMasterClientMockRecorder 

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

MockMasterClientMockRecorder is the mock recorder for MockMasterClient

func (*MockMasterClientMockRecorder) BreakWorkerDDLLock 

func (mr *MockMasterClientMockRecorder) BreakWorkerDDLLock(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

BreakWorkerDDLLock indicates an expected call of BreakWorkerDDLLock

func (*MockMasterClientMockRecorder) CheckTask 

func (mr *MockMasterClientMockRecorder) CheckTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CheckTask indicates an expected call of CheckTask

func (*MockMasterClientMockRecorder) HandleSQLs 

func (mr *MockMasterClientMockRecorder) HandleSQLs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

HandleSQLs indicates an expected call of HandleSQLs

func (*MockMasterClientMockRecorder) MigrateWorkerRelay 

func (mr *MockMasterClientMockRecorder) MigrateWorkerRelay(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

MigrateWorkerRelay indicates an expected call of MigrateWorkerRelay

func (*MockMasterClientMockRecorder) OperateTask 

func (mr *MockMasterClientMockRecorder) OperateTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

OperateTask indicates an expected call of OperateTask

func (*MockMasterClientMockRecorder) OperateWorkerRelayTask 

func (mr *MockMasterClientMockRecorder) OperateWorkerRelayTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

OperateWorkerRelayTask indicates an expected call of OperateWorkerRelayTask

func (*MockMasterClientMockRecorder) PurgeWorkerRelay 

func (mr *MockMasterClientMockRecorder) PurgeWorkerRelay(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PurgeWorkerRelay indicates an expected call of PurgeWorkerRelay

func (*MockMasterClientMockRecorder) QueryError 

func (mr *MockMasterClientMockRecorder) QueryError(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryError indicates an expected call of QueryError

func (*MockMasterClientMockRecorder) QueryStatus 

func (mr *MockMasterClientMockRecorder) QueryStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryStatus indicates an expected call of QueryStatus

func (*MockMasterClientMockRecorder) RefreshWorkerTasks 

func (mr *MockMasterClientMockRecorder) RefreshWorkerTasks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RefreshWorkerTasks indicates an expected call of RefreshWorkerTasks

func (*MockMasterClientMockRecorder) ShowDDLLocks 

func (mr *MockMasterClientMockRecorder) ShowDDLLocks(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ShowDDLLocks indicates an expected call of ShowDDLLocks

func (*MockMasterClientMockRecorder) StartTask 

func (mr *MockMasterClientMockRecorder) StartTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StartTask indicates an expected call of StartTask

func (*MockMasterClientMockRecorder) SwitchWorkerRelayMaster 

func (mr *MockMasterClientMockRecorder) SwitchWorkerRelayMaster(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SwitchWorkerRelayMaster indicates an expected call of SwitchWorkerRelayMaster

func (*MockMasterClientMockRecorder) UnlockDDLLock 

func (mr *MockMasterClientMockRecorder) UnlockDDLLock(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UnlockDDLLock indicates an expected call of UnlockDDLLock

func (*MockMasterClientMockRecorder) UpdateMasterConfig 

func (mr *MockMasterClientMockRecorder) UpdateMasterConfig(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateMasterConfig indicates an expected call of UpdateMasterConfig

func (*MockMasterClientMockRecorder) UpdateTask 

func (mr *MockMasterClientMockRecorder) UpdateTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateTask indicates an expected call of UpdateTask

func (*MockMasterClientMockRecorder) UpdateWorkerRelayConfig 

func (mr *MockMasterClientMockRecorder) UpdateWorkerRelayConfig(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateWorkerRelayConfig indicates an expected call of UpdateWorkerRelayConfig

type MockMasterServer 

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

MockMasterServer is a mock of MasterServer interface

func NewMockMasterServer 

func NewMockMasterServer(ctrl *gomock.Controller) *MockMasterServer

NewMockMasterServer creates a new mock instance

func (*MockMasterServer) BreakWorkerDDLLock 

func (m *MockMasterServer) BreakWorkerDDLLock(arg0 context.Context, arg1 *pb.BreakWorkerDDLLockRequest) (*pb.BreakWorkerDDLLockResponse, error)

BreakWorkerDDLLock mocks base method

func (*MockMasterServer) CheckTask 

func (m *MockMasterServer) CheckTask(arg0 context.Context, arg1 *pb.CheckTaskRequest) (*pb.CheckTaskResponse, error)

CheckTask mocks base method

func (*MockMasterServer) EXPECT 

func (m *MockMasterServer) EXPECT() *MockMasterServerMockRecorder

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

func (*MockMasterServer) HandleSQLs 

func (m *MockMasterServer) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSQLsRequest) (*pb.HandleSQLsResponse, error)

HandleSQLs mocks base method

func (*MockMasterServer) MigrateWorkerRelay 

func (m *MockMasterServer) MigrateWorkerRelay(arg0 context.Context, arg1 *pb.MigrateWorkerRelayRequest) (*pb.CommonWorkerResponse, error)

MigrateWorkerRelay mocks base method

func (*MockMasterServer) OperateTask 

func (m *MockMasterServer) OperateTask(arg0 context.Context, arg1 *pb.OperateTaskRequest) (*pb.OperateTaskResponse, error)

OperateTask mocks base method

func (*MockMasterServer) OperateWorkerRelayTask 

func (m *MockMasterServer) OperateWorkerRelayTask(arg0 context.Context, arg1 *pb.OperateWorkerRelayRequest) (*pb.OperateWorkerRelayResponse, error)

OperateWorkerRelayTask mocks base method

func (*MockMasterServer) PurgeWorkerRelay 

func (m *MockMasterServer) PurgeWorkerRelay(arg0 context.Context, arg1 *pb.PurgeWorkerRelayRequest) (*pb.PurgeWorkerRelayResponse, error)

PurgeWorkerRelay mocks base method

func (*MockMasterServer) QueryError 

func (m *MockMasterServer) QueryError(arg0 context.Context, arg1 *pb.QueryErrorListRequest) (*pb.QueryErrorListResponse, error)

QueryError mocks base method

func (*MockMasterServer) QueryStatus 

func (m *MockMasterServer) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusListRequest) (*pb.QueryStatusListResponse, error)

QueryStatus mocks base method

func (*MockMasterServer) RefreshWorkerTasks 

func (m *MockMasterServer) RefreshWorkerTasks(arg0 context.Context, arg1 *pb.RefreshWorkerTasksRequest) (*pb.RefreshWorkerTasksResponse, error)

RefreshWorkerTasks mocks base method

func (*MockMasterServer) ShowDDLLocks 

func (m *MockMasterServer) ShowDDLLocks(arg0 context.Context, arg1 *pb.ShowDDLLocksRequest) (*pb.ShowDDLLocksResponse, error)

ShowDDLLocks mocks base method

func (*MockMasterServer) StartTask 

func (m *MockMasterServer) StartTask(arg0 context.Context, arg1 *pb.StartTaskRequest) (*pb.StartTaskResponse, error)

StartTask mocks base method

func (*MockMasterServer) SwitchWorkerRelayMaster 

func (m *MockMasterServer) SwitchWorkerRelayMaster(arg0 context.Context, arg1 *pb.SwitchWorkerRelayMasterRequest) (*pb.SwitchWorkerRelayMasterResponse, error)

SwitchWorkerRelayMaster mocks base method

func (*MockMasterServer) UnlockDDLLock 

func (m *MockMasterServer) UnlockDDLLock(arg0 context.Context, arg1 *pb.UnlockDDLLockRequest) (*pb.UnlockDDLLockResponse, error)

UnlockDDLLock mocks base method

func (*MockMasterServer) UpdateMasterConfig 

func (m *MockMasterServer) UpdateMasterConfig(arg0 context.Context, arg1 *pb.UpdateMasterConfigRequest) (*pb.UpdateMasterConfigResponse, error)

UpdateMasterConfig mocks base method

func (*MockMasterServer) UpdateTask 

func (m *MockMasterServer) UpdateTask(arg0 context.Context, arg1 *pb.UpdateTaskRequest) (*pb.UpdateTaskResponse, error)

UpdateTask mocks base method

func (*MockMasterServer) UpdateWorkerRelayConfig 

func (m *MockMasterServer) UpdateWorkerRelayConfig(arg0 context.Context, arg1 *pb.UpdateWorkerRelayConfigRequest) (*pb.CommonWorkerResponse, error)

UpdateWorkerRelayConfig mocks base method

type MockMasterServerMockRecorder 

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

MockMasterServerMockRecorder is the mock recorder for MockMasterServer

func (*MockMasterServerMockRecorder) BreakWorkerDDLLock 

func (mr *MockMasterServerMockRecorder) BreakWorkerDDLLock(arg0, arg1 interface{}) *gomock.Call

BreakWorkerDDLLock indicates an expected call of BreakWorkerDDLLock

func (*MockMasterServerMockRecorder) CheckTask 

func (mr *MockMasterServerMockRecorder) CheckTask(arg0, arg1 interface{}) *gomock.Call

CheckTask indicates an expected call of CheckTask

func (*MockMasterServerMockRecorder) HandleSQLs 

func (mr *MockMasterServerMockRecorder) HandleSQLs(arg0, arg1 interface{}) *gomock.Call

HandleSQLs indicates an expected call of HandleSQLs

func (*MockMasterServerMockRecorder) MigrateWorkerRelay 

func (mr *MockMasterServerMockRecorder) MigrateWorkerRelay(arg0, arg1 interface{}) *gomock.Call

MigrateWorkerRelay indicates an expected call of MigrateWorkerRelay

func (*MockMasterServerMockRecorder) OperateTask 

func (mr *MockMasterServerMockRecorder) OperateTask(arg0, arg1 interface{}) *gomock.Call

OperateTask indicates an expected call of OperateTask

func (*MockMasterServerMockRecorder) OperateWorkerRelayTask 

func (mr *MockMasterServerMockRecorder) OperateWorkerRelayTask(arg0, arg1 interface{}) *gomock.Call

OperateWorkerRelayTask indicates an expected call of OperateWorkerRelayTask

func (*MockMasterServerMockRecorder) PurgeWorkerRelay 

func (mr *MockMasterServerMockRecorder) PurgeWorkerRelay(arg0, arg1 interface{}) *gomock.Call

PurgeWorkerRelay indicates an expected call of PurgeWorkerRelay

func (*MockMasterServerMockRecorder) QueryError 

func (mr *MockMasterServerMockRecorder) QueryError(arg0, arg1 interface{}) *gomock.Call

QueryError indicates an expected call of QueryError

func (*MockMasterServerMockRecorder) QueryStatus 

func (mr *MockMasterServerMockRecorder) QueryStatus(arg0, arg1 interface{}) *gomock.Call

QueryStatus indicates an expected call of QueryStatus

func (*MockMasterServerMockRecorder) RefreshWorkerTasks 

func (mr *MockMasterServerMockRecorder) RefreshWorkerTasks(arg0, arg1 interface{}) *gomock.Call

RefreshWorkerTasks indicates an expected call of RefreshWorkerTasks

func (*MockMasterServerMockRecorder) ShowDDLLocks 

func (mr *MockMasterServerMockRecorder) ShowDDLLocks(arg0, arg1 interface{}) *gomock.Call

ShowDDLLocks indicates an expected call of ShowDDLLocks

func (*MockMasterServerMockRecorder) StartTask 

func (mr *MockMasterServerMockRecorder) StartTask(arg0, arg1 interface{}) *gomock.Call

StartTask indicates an expected call of StartTask

func (*MockMasterServerMockRecorder) SwitchWorkerRelayMaster 

func (mr *MockMasterServerMockRecorder) SwitchWorkerRelayMaster(arg0, arg1 interface{}) *gomock.Call

SwitchWorkerRelayMaster indicates an expected call of SwitchWorkerRelayMaster

func (*MockMasterServerMockRecorder) UnlockDDLLock 

func (mr *MockMasterServerMockRecorder) UnlockDDLLock(arg0, arg1 interface{}) *gomock.Call

UnlockDDLLock indicates an expected call of UnlockDDLLock

func (*MockMasterServerMockRecorder) UpdateMasterConfig 

func (mr *MockMasterServerMockRecorder) UpdateMasterConfig(arg0, arg1 interface{}) *gomock.Call

UpdateMasterConfig indicates an expected call of UpdateMasterConfig

func (*MockMasterServerMockRecorder) UpdateTask 

func (mr *MockMasterServerMockRecorder) UpdateTask(arg0, arg1 interface{}) *gomock.Call

UpdateTask indicates an expected call of UpdateTask

func (*MockMasterServerMockRecorder) UpdateWorkerRelayConfig 

func (mr *MockMasterServerMockRecorder) UpdateWorkerRelayConfig(arg0, arg1 interface{}) *gomock.Call

UpdateWorkerRelayConfig indicates an expected call of UpdateWorkerRelayConfig

type MockWorkerClient 

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

MockWorkerClient is a mock of WorkerClient interface

func NewMockWorkerClient 

func NewMockWorkerClient(ctrl *gomock.Controller) *MockWorkerClient

NewMockWorkerClient creates a new mock instance

func (*MockWorkerClient) BreakDDLLock 

func (m *MockWorkerClient) BreakDDLLock(arg0 context.Context, arg1 *pb.BreakDDLLockRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

BreakDDLLock mocks base method

func (*MockWorkerClient) EXPECT 

func (m *MockWorkerClient) EXPECT() *MockWorkerClientMockRecorder

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

func (*MockWorkerClient) ExecuteDDL 

func (m *MockWorkerClient) ExecuteDDL(arg0 context.Context, arg1 *pb.ExecDDLRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

ExecuteDDL mocks base method

func (*MockWorkerClient) FetchDDLInfo 

func (m *MockWorkerClient) FetchDDLInfo(arg0 context.Context, arg1 ...grpc.CallOption) (pb.Worker_FetchDDLInfoClient, error)

FetchDDLInfo mocks base method

func (*MockWorkerClient) HandleSQLs 

func (m *MockWorkerClient) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSubTaskSQLsRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

HandleSQLs mocks base method

func (*MockWorkerClient) MigrateRelay 

func (m *MockWorkerClient) MigrateRelay(arg0 context.Context, arg1 *pb.MigrateRelayRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

MigrateRelay mocks base method

func (*MockWorkerClient) OperateRelay 

func (m *MockWorkerClient) OperateRelay(arg0 context.Context, arg1 *pb.OperateRelayRequest, arg2 ...grpc.CallOption) (*pb.OperateRelayResponse, error)

OperateRelay mocks base method

func (*MockWorkerClient) OperateSubTask 

func (m *MockWorkerClient) OperateSubTask(arg0 context.Context, arg1 *pb.OperateSubTaskRequest, arg2 ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)

OperateSubTask mocks base method

func (*MockWorkerClient) PurgeRelay 

func (m *MockWorkerClient) PurgeRelay(arg0 context.Context, arg1 *pb.PurgeRelayRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

PurgeRelay mocks base method

func (*MockWorkerClient) QueryError 

func (m *MockWorkerClient) QueryError(arg0 context.Context, arg1 *pb.QueryErrorRequest, arg2 ...grpc.CallOption) (*pb.QueryErrorResponse, error)

QueryError mocks base method

func (*MockWorkerClient) QueryStatus 

func (m *MockWorkerClient) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusRequest, arg2 ...grpc.CallOption) (*pb.QueryStatusResponse, error)

QueryStatus mocks base method

func (*MockWorkerClient) QueryTaskOperation 

func (m *MockWorkerClient) QueryTaskOperation(arg0 context.Context, arg1 *pb.QueryTaskOperationRequest, arg2 ...grpc.CallOption) (*pb.QueryTaskOperationResponse, error)

QueryTaskOperation mocks base method

func (*MockWorkerClient) QueryWorkerConfig 

func (m *MockWorkerClient) QueryWorkerConfig(arg0 context.Context, arg1 *pb.QueryWorkerConfigRequest, arg2 ...grpc.CallOption) (*pb.QueryWorkerConfigResponse, error)

QueryWorkerConfig mocks base method

func (*MockWorkerClient) StartSubTask 

func (m *MockWorkerClient) StartSubTask(arg0 context.Context, arg1 *pb.StartSubTaskRequest, arg2 ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)

StartSubTask mocks base method

func (*MockWorkerClient) SwitchRelayMaster 

func (m *MockWorkerClient) SwitchRelayMaster(arg0 context.Context, arg1 *pb.SwitchRelayMasterRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

SwitchRelayMaster mocks base method

func (*MockWorkerClient) UpdateRelayConfig 

func (m *MockWorkerClient) UpdateRelayConfig(arg0 context.Context, arg1 *pb.UpdateRelayRequest, arg2 ...grpc.CallOption) (*pb.CommonWorkerResponse, error)

UpdateRelayConfig mocks base method

func (*MockWorkerClient) UpdateSubTask 

func (m *MockWorkerClient) UpdateSubTask(arg0 context.Context, arg1 *pb.UpdateSubTaskRequest, arg2 ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)

UpdateSubTask mocks base method

type MockWorkerClientMockRecorder 

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

MockWorkerClientMockRecorder is the mock recorder for MockWorkerClient

func (*MockWorkerClientMockRecorder) BreakDDLLock 

func (mr *MockWorkerClientMockRecorder) BreakDDLLock(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

BreakDDLLock indicates an expected call of BreakDDLLock

func (*MockWorkerClientMockRecorder) ExecuteDDL 

func (mr *MockWorkerClientMockRecorder) ExecuteDDL(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ExecuteDDL indicates an expected call of ExecuteDDL

func (*MockWorkerClientMockRecorder) FetchDDLInfo 

func (mr *MockWorkerClientMockRecorder) FetchDDLInfo(arg0 interface{}, arg1 ...interface{}) *gomock.Call

FetchDDLInfo indicates an expected call of FetchDDLInfo

func (*MockWorkerClientMockRecorder) HandleSQLs 

func (mr *MockWorkerClientMockRecorder) HandleSQLs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

HandleSQLs indicates an expected call of HandleSQLs

func (*MockWorkerClientMockRecorder) MigrateRelay 

func (mr *MockWorkerClientMockRecorder) MigrateRelay(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

MigrateRelay indicates an expected call of MigrateRelay

func (*MockWorkerClientMockRecorder) OperateRelay 

func (mr *MockWorkerClientMockRecorder) OperateRelay(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

OperateRelay indicates an expected call of OperateRelay

func (*MockWorkerClientMockRecorder) OperateSubTask 

func (mr *MockWorkerClientMockRecorder) OperateSubTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

OperateSubTask indicates an expected call of OperateSubTask

func (*MockWorkerClientMockRecorder) PurgeRelay 

func (mr *MockWorkerClientMockRecorder) PurgeRelay(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PurgeRelay indicates an expected call of PurgeRelay

func (*MockWorkerClientMockRecorder) QueryError 

func (mr *MockWorkerClientMockRecorder) QueryError(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryError indicates an expected call of QueryError

func (*MockWorkerClientMockRecorder) QueryStatus 

func (mr *MockWorkerClientMockRecorder) QueryStatus(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryStatus indicates an expected call of QueryStatus

func (*MockWorkerClientMockRecorder) QueryTaskOperation 

func (mr *MockWorkerClientMockRecorder) QueryTaskOperation(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryTaskOperation indicates an expected call of QueryTaskOperation

func (*MockWorkerClientMockRecorder) QueryWorkerConfig 

func (mr *MockWorkerClientMockRecorder) QueryWorkerConfig(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryWorkerConfig indicates an expected call of QueryWorkerConfig

func (*MockWorkerClientMockRecorder) StartSubTask 

func (mr *MockWorkerClientMockRecorder) StartSubTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

StartSubTask indicates an expected call of StartSubTask

func (*MockWorkerClientMockRecorder) SwitchRelayMaster 

func (mr *MockWorkerClientMockRecorder) SwitchRelayMaster(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SwitchRelayMaster indicates an expected call of SwitchRelayMaster

func (*MockWorkerClientMockRecorder) UpdateRelayConfig 

func (mr *MockWorkerClientMockRecorder) UpdateRelayConfig(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateRelayConfig indicates an expected call of UpdateRelayConfig

func (*MockWorkerClientMockRecorder) UpdateSubTask 

func (mr *MockWorkerClientMockRecorder) UpdateSubTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateSubTask indicates an expected call of UpdateSubTask

type MockWorkerServer 

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

MockWorkerServer is a mock of WorkerServer interface

func NewMockWorkerServer 

func NewMockWorkerServer(ctrl *gomock.Controller) *MockWorkerServer

NewMockWorkerServer creates a new mock instance

func (*MockWorkerServer) BreakDDLLock 

func (m *MockWorkerServer) BreakDDLLock(arg0 context.Context, arg1 *pb.BreakDDLLockRequest) (*pb.CommonWorkerResponse, error)

BreakDDLLock mocks base method

func (*MockWorkerServer) EXPECT 

func (m *MockWorkerServer) EXPECT() *MockWorkerServerMockRecorder

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

func (*MockWorkerServer) ExecuteDDL 

func (m *MockWorkerServer) ExecuteDDL(arg0 context.Context, arg1 *pb.ExecDDLRequest) (*pb.CommonWorkerResponse, error)

ExecuteDDL mocks base method

func (*MockWorkerServer) FetchDDLInfo 

func (m *MockWorkerServer) FetchDDLInfo(arg0 pb.Worker_FetchDDLInfoServer) error

FetchDDLInfo mocks base method

func (*MockWorkerServer) HandleSQLs 

func (m *MockWorkerServer) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSubTaskSQLsRequest) (*pb.CommonWorkerResponse, error)

HandleSQLs mocks base method

func (*MockWorkerServer) MigrateRelay 

func (m *MockWorkerServer) MigrateRelay(arg0 context.Context, arg1 *pb.MigrateRelayRequest) (*pb.CommonWorkerResponse, error)

MigrateRelay mocks base method

func (*MockWorkerServer) OperateRelay 

func (m *MockWorkerServer) OperateRelay(arg0 context.Context, arg1 *pb.OperateRelayRequest) (*pb.OperateRelayResponse, error)

OperateRelay mocks base method

func (*MockWorkerServer) OperateSubTask 

func (m *MockWorkerServer) OperateSubTask(arg0 context.Context, arg1 *pb.OperateSubTaskRequest) (*pb.OperateSubTaskResponse, error)

OperateSubTask mocks base method

func (*MockWorkerServer) PurgeRelay 

func (m *MockWorkerServer) PurgeRelay(arg0 context.Context, arg1 *pb.PurgeRelayRequest) (*pb.CommonWorkerResponse, error)

PurgeRelay mocks base method

func (*MockWorkerServer) QueryError 

func (m *MockWorkerServer) QueryError(arg0 context.Context, arg1 *pb.QueryErrorRequest) (*pb.QueryErrorResponse, error)

QueryError mocks base method

func (*MockWorkerServer) QueryStatus 

func (m *MockWorkerServer) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusRequest) (*pb.QueryStatusResponse, error)

QueryStatus mocks base method

func (*MockWorkerServer) QueryTaskOperation 

func (m *MockWorkerServer) QueryTaskOperation(arg0 context.Context, arg1 *pb.QueryTaskOperationRequest) (*pb.QueryTaskOperationResponse, error)

QueryTaskOperation mocks base method

func (*MockWorkerServer) QueryWorkerConfig 

func (m *MockWorkerServer) QueryWorkerConfig(arg0 context.Context, arg1 *pb.QueryWorkerConfigRequest) (*pb.QueryWorkerConfigResponse, error)

QueryWorkerConfig mocks base method

func (*MockWorkerServer) StartSubTask 

func (m *MockWorkerServer) StartSubTask(arg0 context.Context, arg1 *pb.StartSubTaskRequest) (*pb.OperateSubTaskResponse, error)

StartSubTask mocks base method

func (*MockWorkerServer) SwitchRelayMaster 

func (m *MockWorkerServer) SwitchRelayMaster(arg0 context.Context, arg1 *pb.SwitchRelayMasterRequest) (*pb.CommonWorkerResponse, error)

SwitchRelayMaster mocks base method

func (*MockWorkerServer) UpdateRelayConfig 

func (m *MockWorkerServer) UpdateRelayConfig(arg0 context.Context, arg1 *pb.UpdateRelayRequest) (*pb.CommonWorkerResponse, error)

UpdateRelayConfig mocks base method

func (*MockWorkerServer) UpdateSubTask 

func (m *MockWorkerServer) UpdateSubTask(arg0 context.Context, arg1 *pb.UpdateSubTaskRequest) (*pb.OperateSubTaskResponse, error)

UpdateSubTask mocks base method

type MockWorkerServerMockRecorder 

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

MockWorkerServerMockRecorder is the mock recorder for MockWorkerServer

func (*MockWorkerServerMockRecorder) BreakDDLLock 

func (mr *MockWorkerServerMockRecorder) BreakDDLLock(arg0, arg1 interface{}) *gomock.Call

BreakDDLLock indicates an expected call of BreakDDLLock

func (*MockWorkerServerMockRecorder) ExecuteDDL 

func (mr *MockWorkerServerMockRecorder) ExecuteDDL(arg0, arg1 interface{}) *gomock.Call

ExecuteDDL indicates an expected call of ExecuteDDL

func (*MockWorkerServerMockRecorder) FetchDDLInfo 

func (mr *MockWorkerServerMockRecorder) FetchDDLInfo(arg0 interface{}) *gomock.Call

FetchDDLInfo indicates an expected call of FetchDDLInfo

func (*MockWorkerServerMockRecorder) HandleSQLs 

func (mr *MockWorkerServerMockRecorder) HandleSQLs(arg0, arg1 interface{}) *gomock.Call

HandleSQLs indicates an expected call of HandleSQLs

func (*MockWorkerServerMockRecorder) MigrateRelay 

func (mr *MockWorkerServerMockRecorder) MigrateRelay(arg0, arg1 interface{}) *gomock.Call

MigrateRelay indicates an expected call of MigrateRelay

func (*MockWorkerServerMockRecorder) OperateRelay 

func (mr *MockWorkerServerMockRecorder) OperateRelay(arg0, arg1 interface{}) *gomock.Call

OperateRelay indicates an expected call of OperateRelay

func (*MockWorkerServerMockRecorder) OperateSubTask 

func (mr *MockWorkerServerMockRecorder) OperateSubTask(arg0, arg1 interface{}) *gomock.Call

OperateSubTask indicates an expected call of OperateSubTask

func (*MockWorkerServerMockRecorder) PurgeRelay 

func (mr *MockWorkerServerMockRecorder) PurgeRelay(arg0, arg1 interface{}) *gomock.Call

PurgeRelay indicates an expected call of PurgeRelay

func (*MockWorkerServerMockRecorder) QueryError 

func (mr *MockWorkerServerMockRecorder) QueryError(arg0, arg1 interface{}) *gomock.Call

QueryError indicates an expected call of QueryError

func (*MockWorkerServerMockRecorder) QueryStatus 

func (mr *MockWorkerServerMockRecorder) QueryStatus(arg0, arg1 interface{}) *gomock.Call

QueryStatus indicates an expected call of QueryStatus

func (*MockWorkerServerMockRecorder) QueryTaskOperation 

func (mr *MockWorkerServerMockRecorder) QueryTaskOperation(arg0, arg1 interface{}) *gomock.Call

QueryTaskOperation indicates an expected call of QueryTaskOperation

func (*MockWorkerServerMockRecorder) QueryWorkerConfig 

func (mr *MockWorkerServerMockRecorder) QueryWorkerConfig(arg0, arg1 interface{}) *gomock.Call

QueryWorkerConfig indicates an expected call of QueryWorkerConfig

func (*MockWorkerServerMockRecorder) StartSubTask 

func (mr *MockWorkerServerMockRecorder) StartSubTask(arg0, arg1 interface{}) *gomock.Call

StartSubTask indicates an expected call of StartSubTask

func (*MockWorkerServerMockRecorder) SwitchRelayMaster 

func (mr *MockWorkerServerMockRecorder) SwitchRelayMaster(arg0, arg1 interface{}) *gomock.Call

SwitchRelayMaster indicates an expected call of SwitchRelayMaster

func (*MockWorkerServerMockRecorder) UpdateRelayConfig 

func (mr *MockWorkerServerMockRecorder) UpdateRelayConfig(arg0, arg1 interface{}) *gomock.Call

UpdateRelayConfig indicates an expected call of UpdateRelayConfig

func (*MockWorkerServerMockRecorder) UpdateSubTask 

func (mr *MockWorkerServerMockRecorder) UpdateSubTask(arg0, arg1 interface{}) *gomock.Call

UpdateSubTask indicates an expected call of UpdateSubTask

type MockWorker_FetchDDLInfoClient 

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

MockWorker_FetchDDLInfoClient is a mock of Worker_FetchDDLInfoClient interface

func NewMockWorker_FetchDDLInfoClient 

func NewMockWorker_FetchDDLInfoClient(ctrl *gomock.Controller) *MockWorker_FetchDDLInfoClient

NewMockWorker_FetchDDLInfoClient creates a new mock instance

func (*MockWorker_FetchDDLInfoClient) CloseSend 

func (m *MockWorker_FetchDDLInfoClient) CloseSend() error

CloseSend mocks base method

func (*MockWorker_FetchDDLInfoClient) Context 

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

Context mocks base method

func (*MockWorker_FetchDDLInfoClient) EXPECT 

func (m *MockWorker_FetchDDLInfoClient) EXPECT() *MockWorker_FetchDDLInfoClientMockRecorder

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

func (*MockWorker_FetchDDLInfoClient) Header 

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

Header mocks base method

func (*MockWorker_FetchDDLInfoClient) Recv 

func (m *MockWorker_FetchDDLInfoClient) Recv() (*pb.DDLInfo, error)

Recv mocks base method

func (*MockWorker_FetchDDLInfoClient) RecvMsg 

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

RecvMsg mocks base method

func (*MockWorker_FetchDDLInfoClient) Send 

func (m *MockWorker_FetchDDLInfoClient) Send(arg0 *pb.DDLLockInfo) error

Send mocks base method

func (*MockWorker_FetchDDLInfoClient) SendMsg 

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

SendMsg mocks base method

func (*MockWorker_FetchDDLInfoClient) Trailer 

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

Trailer mocks base method

type MockWorker_FetchDDLInfoClientMockRecorder 

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

MockWorker_FetchDDLInfoClientMockRecorder is the mock recorder for MockWorker_FetchDDLInfoClient

func (*MockWorker_FetchDDLInfoClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend

func (*MockWorker_FetchDDLInfoClientMockRecorder) Context 

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

Context indicates an expected call of Context

func (*MockWorker_FetchDDLInfoClientMockRecorder) Header 

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

Header indicates an expected call of Header

func (*MockWorker_FetchDDLInfoClientMockRecorder) Recv 

func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockWorker_FetchDDLInfoClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockWorker_FetchDDLInfoClientMockRecorder) Send 

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

Send indicates an expected call of Send

func (*MockWorker_FetchDDLInfoClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg

func (*MockWorker_FetchDDLInfoClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer

type MockWorker_FetchDDLInfoServer 

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

MockWorker_FetchDDLInfoServer is a mock of Worker_FetchDDLInfoServer interface

func NewMockWorker_FetchDDLInfoServer 

func NewMockWorker_FetchDDLInfoServer(ctrl *gomock.Controller) *MockWorker_FetchDDLInfoServer

NewMockWorker_FetchDDLInfoServer creates a new mock instance

func (*MockWorker_FetchDDLInfoServer) Context 

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

Context mocks base method

func (*MockWorker_FetchDDLInfoServer) EXPECT 

func (m *MockWorker_FetchDDLInfoServer) EXPECT() *MockWorker_FetchDDLInfoServerMockRecorder

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

func (*MockWorker_FetchDDLInfoServer) Recv 

func (m *MockWorker_FetchDDLInfoServer) Recv() (*pb.DDLLockInfo, error)

Recv mocks base method

func (*MockWorker_FetchDDLInfoServer) RecvMsg 

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

RecvMsg mocks base method

func (*MockWorker_FetchDDLInfoServer) Send 

func (m *MockWorker_FetchDDLInfoServer) Send(arg0 *pb.DDLInfo) error

Send mocks base method

func (*MockWorker_FetchDDLInfoServer) SendHeader 

func (m *MockWorker_FetchDDLInfoServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockWorker_FetchDDLInfoServer) SendMsg 

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

SendMsg mocks base method

func (*MockWorker_FetchDDLInfoServer) SetHeader 

func (m *MockWorker_FetchDDLInfoServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockWorker_FetchDDLInfoServer) SetTrailer 

func (m *MockWorker_FetchDDLInfoServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockWorker_FetchDDLInfoServerMockRecorder 

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

MockWorker_FetchDDLInfoServerMockRecorder is the mock recorder for MockWorker_FetchDDLInfoServer

func (*MockWorker_FetchDDLInfoServerMockRecorder) Context 

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

Context indicates an expected call of Context

func (*MockWorker_FetchDDLInfoServerMockRecorder) Recv 

func (mr *MockWorker_FetchDDLInfoServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockWorker_FetchDDLInfoServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockWorker_FetchDDLInfoServerMockRecorder) Send 

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

Send indicates an expected call of Send

func (*MockWorker_FetchDDLInfoServerMockRecorder) SendHeader 

func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockWorker_FetchDDLInfoServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg

func (*MockWorker_FetchDDLInfoServerMockRecorder) SetHeader 

func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockWorker_FetchDDLInfoServerMockRecorder) SetTrailer 

func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

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.