Documentation ¶
Overview ¶
Package pbmock is a generated GoMock package.
Package pbmock is a generated GoMock package.
Index ¶
- type MockMasterClient
- func (m *MockMasterClient) BreakWorkerDDLLock(ctx context.Context, in *pb.BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*pb.BreakWorkerDDLLockResponse, error)
- func (m *MockMasterClient) CheckTask(ctx context.Context, in *pb.CheckTaskRequest, opts ...grpc.CallOption) (*pb.CheckTaskResponse, error)
- func (m *MockMasterClient) EXPECT() *MockMasterClientMockRecorder
- func (m *MockMasterClient) HandleSQLs(ctx context.Context, in *pb.HandleSQLsRequest, opts ...grpc.CallOption) (*pb.HandleSQLsResponse, error)
- func (m *MockMasterClient) MigrateWorkerRelay(ctx context.Context, in *pb.MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockMasterClient) OperateTask(ctx context.Context, in *pb.OperateTaskRequest, opts ...grpc.CallOption) (*pb.OperateTaskResponse, error)
- func (m *MockMasterClient) OperateWorkerRelayTask(ctx context.Context, in *pb.OperateWorkerRelayRequest, opts ...grpc.CallOption) (*pb.OperateWorkerRelayResponse, error)
- func (m *MockMasterClient) PurgeWorkerRelay(ctx context.Context, in *pb.PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*pb.PurgeWorkerRelayResponse, error)
- func (m *MockMasterClient) QueryError(ctx context.Context, in *pb.QueryErrorListRequest, opts ...grpc.CallOption) (*pb.QueryErrorListResponse, error)
- func (m *MockMasterClient) QueryStatus(ctx context.Context, in *pb.QueryStatusListRequest, opts ...grpc.CallOption) (*pb.QueryStatusListResponse, error)
- func (m *MockMasterClient) RefreshWorkerTasks(ctx context.Context, in *pb.RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*pb.RefreshWorkerTasksResponse, error)
- func (m *MockMasterClient) ShowDDLLocks(ctx context.Context, in *pb.ShowDDLLocksRequest, opts ...grpc.CallOption) (*pb.ShowDDLLocksResponse, error)
- func (m *MockMasterClient) StartTask(ctx context.Context, in *pb.StartTaskRequest, opts ...grpc.CallOption) (*pb.StartTaskResponse, error)
- func (m *MockMasterClient) SwitchWorkerRelayMaster(ctx context.Context, in *pb.SwitchWorkerRelayMasterRequest, ...) (*pb.SwitchWorkerRelayMasterResponse, error)
- func (m *MockMasterClient) UnlockDDLLock(ctx context.Context, in *pb.UnlockDDLLockRequest, opts ...grpc.CallOption) (*pb.UnlockDDLLockResponse, error)
- func (m *MockMasterClient) UpdateMasterConfig(ctx context.Context, in *pb.UpdateMasterConfigRequest, opts ...grpc.CallOption) (*pb.UpdateMasterConfigResponse, error)
- func (m *MockMasterClient) UpdateTask(ctx context.Context, in *pb.UpdateTaskRequest, opts ...grpc.CallOption) (*pb.UpdateTaskResponse, error)
- func (m *MockMasterClient) UpdateWorkerRelayConfig(ctx context.Context, in *pb.UpdateWorkerRelayConfigRequest, ...) (*pb.CommonWorkerResponse, error)
- type MockMasterClientMockRecorder
- func (mr *MockMasterClientMockRecorder) BreakWorkerDDLLock(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) CheckTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) HandleSQLs(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) MigrateWorkerRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) OperateTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) OperateWorkerRelayTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) PurgeWorkerRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) QueryError(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) QueryStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) RefreshWorkerTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) ShowDDLLocks(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) StartTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) SwitchWorkerRelayMaster(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) UnlockDDLLock(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) UpdateMasterConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) UpdateTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMasterClientMockRecorder) UpdateWorkerRelayConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockMasterServer
- func (m *MockMasterServer) BreakWorkerDDLLock(arg0 context.Context, arg1 *pb.BreakWorkerDDLLockRequest) (*pb.BreakWorkerDDLLockResponse, error)
- func (m *MockMasterServer) CheckTask(arg0 context.Context, arg1 *pb.CheckTaskRequest) (*pb.CheckTaskResponse, error)
- func (m *MockMasterServer) EXPECT() *MockMasterServerMockRecorder
- func (m *MockMasterServer) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSQLsRequest) (*pb.HandleSQLsResponse, error)
- func (m *MockMasterServer) MigrateWorkerRelay(arg0 context.Context, arg1 *pb.MigrateWorkerRelayRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockMasterServer) OperateTask(arg0 context.Context, arg1 *pb.OperateTaskRequest) (*pb.OperateTaskResponse, error)
- func (m *MockMasterServer) OperateWorkerRelayTask(arg0 context.Context, arg1 *pb.OperateWorkerRelayRequest) (*pb.OperateWorkerRelayResponse, error)
- func (m *MockMasterServer) PurgeWorkerRelay(arg0 context.Context, arg1 *pb.PurgeWorkerRelayRequest) (*pb.PurgeWorkerRelayResponse, error)
- func (m *MockMasterServer) QueryError(arg0 context.Context, arg1 *pb.QueryErrorListRequest) (*pb.QueryErrorListResponse, error)
- func (m *MockMasterServer) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusListRequest) (*pb.QueryStatusListResponse, error)
- func (m *MockMasterServer) RefreshWorkerTasks(arg0 context.Context, arg1 *pb.RefreshWorkerTasksRequest) (*pb.RefreshWorkerTasksResponse, error)
- func (m *MockMasterServer) ShowDDLLocks(arg0 context.Context, arg1 *pb.ShowDDLLocksRequest) (*pb.ShowDDLLocksResponse, error)
- func (m *MockMasterServer) StartTask(arg0 context.Context, arg1 *pb.StartTaskRequest) (*pb.StartTaskResponse, error)
- func (m *MockMasterServer) SwitchWorkerRelayMaster(arg0 context.Context, arg1 *pb.SwitchWorkerRelayMasterRequest) (*pb.SwitchWorkerRelayMasterResponse, error)
- func (m *MockMasterServer) UnlockDDLLock(arg0 context.Context, arg1 *pb.UnlockDDLLockRequest) (*pb.UnlockDDLLockResponse, error)
- func (m *MockMasterServer) UpdateMasterConfig(arg0 context.Context, arg1 *pb.UpdateMasterConfigRequest) (*pb.UpdateMasterConfigResponse, error)
- func (m *MockMasterServer) UpdateTask(arg0 context.Context, arg1 *pb.UpdateTaskRequest) (*pb.UpdateTaskResponse, error)
- func (m *MockMasterServer) UpdateWorkerRelayConfig(arg0 context.Context, arg1 *pb.UpdateWorkerRelayConfigRequest) (*pb.CommonWorkerResponse, error)
- type MockMasterServerMockRecorder
- func (mr *MockMasterServerMockRecorder) BreakWorkerDDLLock(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) CheckTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) HandleSQLs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) MigrateWorkerRelay(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) OperateTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) OperateWorkerRelayTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) PurgeWorkerRelay(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) QueryError(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) QueryStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) RefreshWorkerTasks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) ShowDDLLocks(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) StartTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) SwitchWorkerRelayMaster(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) UnlockDDLLock(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) UpdateMasterConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) UpdateTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMasterServerMockRecorder) UpdateWorkerRelayConfig(arg0, arg1 interface{}) *gomock.Call
- type MockWorkerClient
- func (m *MockWorkerClient) BreakDDLLock(ctx context.Context, in *pb.BreakDDLLockRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) EXPECT() *MockWorkerClientMockRecorder
- func (m *MockWorkerClient) ExecuteDDL(ctx context.Context, in *pb.ExecDDLRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) FetchDDLInfo(ctx context.Context, opts ...grpc.CallOption) (pb.Worker_FetchDDLInfoClient, error)
- func (m *MockWorkerClient) HandleSQLs(ctx context.Context, in *pb.HandleSubTaskSQLsRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) MigrateRelay(ctx context.Context, in *pb.MigrateRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) OperateRelay(ctx context.Context, in *pb.OperateRelayRequest, opts ...grpc.CallOption) (*pb.OperateRelayResponse, error)
- func (m *MockWorkerClient) OperateSubTask(ctx context.Context, in *pb.OperateSubTaskRequest, opts ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)
- func (m *MockWorkerClient) PurgeRelay(ctx context.Context, in *pb.PurgeRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) QueryError(ctx context.Context, in *pb.QueryErrorRequest, opts ...grpc.CallOption) (*pb.QueryErrorResponse, error)
- func (m *MockWorkerClient) QueryStatus(ctx context.Context, in *pb.QueryStatusRequest, opts ...grpc.CallOption) (*pb.QueryStatusResponse, error)
- func (m *MockWorkerClient) QueryTaskOperation(ctx context.Context, in *pb.QueryTaskOperationRequest, opts ...grpc.CallOption) (*pb.QueryTaskOperationResponse, error)
- func (m *MockWorkerClient) QueryWorkerConfig(ctx context.Context, in *pb.QueryWorkerConfigRequest, opts ...grpc.CallOption) (*pb.QueryWorkerConfigResponse, error)
- func (m *MockWorkerClient) StartSubTask(ctx context.Context, in *pb.StartSubTaskRequest, opts ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)
- func (m *MockWorkerClient) SwitchRelayMaster(ctx context.Context, in *pb.SwitchRelayMasterRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) UpdateRelayConfig(ctx context.Context, in *pb.UpdateRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerClient) UpdateSubTask(ctx context.Context, in *pb.UpdateSubTaskRequest, opts ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)
- type MockWorkerClientMockRecorder
- func (mr *MockWorkerClientMockRecorder) BreakDDLLock(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) ExecuteDDL(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) FetchDDLInfo(ctx interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) HandleSQLs(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) MigrateRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) OperateRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) OperateSubTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) PurgeRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) QueryError(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) QueryStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) QueryTaskOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) QueryWorkerConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) StartSubTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) SwitchRelayMaster(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) UpdateRelayConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkerClientMockRecorder) UpdateSubTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockWorkerServer
- func (m *MockWorkerServer) BreakDDLLock(arg0 context.Context, arg1 *pb.BreakDDLLockRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) EXPECT() *MockWorkerServerMockRecorder
- func (m *MockWorkerServer) ExecuteDDL(arg0 context.Context, arg1 *pb.ExecDDLRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) FetchDDLInfo(arg0 pb.Worker_FetchDDLInfoServer) error
- func (m *MockWorkerServer) HandleSQLs(arg0 context.Context, arg1 *pb.HandleSubTaskSQLsRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) MigrateRelay(arg0 context.Context, arg1 *pb.MigrateRelayRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) OperateRelay(arg0 context.Context, arg1 *pb.OperateRelayRequest) (*pb.OperateRelayResponse, error)
- func (m *MockWorkerServer) OperateSubTask(arg0 context.Context, arg1 *pb.OperateSubTaskRequest) (*pb.OperateSubTaskResponse, error)
- func (m *MockWorkerServer) PurgeRelay(arg0 context.Context, arg1 *pb.PurgeRelayRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) QueryError(arg0 context.Context, arg1 *pb.QueryErrorRequest) (*pb.QueryErrorResponse, error)
- func (m *MockWorkerServer) QueryStatus(arg0 context.Context, arg1 *pb.QueryStatusRequest) (*pb.QueryStatusResponse, error)
- func (m *MockWorkerServer) QueryTaskOperation(arg0 context.Context, arg1 *pb.QueryTaskOperationRequest) (*pb.QueryTaskOperationResponse, error)
- func (m *MockWorkerServer) QueryWorkerConfig(arg0 context.Context, arg1 *pb.QueryWorkerConfigRequest) (*pb.QueryWorkerConfigResponse, error)
- func (m *MockWorkerServer) StartSubTask(arg0 context.Context, arg1 *pb.StartSubTaskRequest) (*pb.OperateSubTaskResponse, error)
- func (m *MockWorkerServer) SwitchRelayMaster(arg0 context.Context, arg1 *pb.SwitchRelayMasterRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) UpdateRelayConfig(arg0 context.Context, arg1 *pb.UpdateRelayRequest) (*pb.CommonWorkerResponse, error)
- func (m *MockWorkerServer) UpdateSubTask(arg0 context.Context, arg1 *pb.UpdateSubTaskRequest) (*pb.OperateSubTaskResponse, error)
- type MockWorkerServerMockRecorder
- func (mr *MockWorkerServerMockRecorder) BreakDDLLock(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) ExecuteDDL(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) FetchDDLInfo(arg0 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) HandleSQLs(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) MigrateRelay(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) OperateRelay(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) OperateSubTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) PurgeRelay(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) QueryError(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) QueryStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) QueryTaskOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) QueryWorkerConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) StartSubTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) SwitchRelayMaster(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) UpdateRelayConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerServerMockRecorder) UpdateSubTask(arg0, arg1 interface{}) *gomock.Call
- type MockWorker_FetchDDLInfoClient
- func (m *MockWorker_FetchDDLInfoClient) CloseSend() error
- func (m *MockWorker_FetchDDLInfoClient) Context() context.Context
- func (m *MockWorker_FetchDDLInfoClient) EXPECT() *MockWorker_FetchDDLInfoClientMockRecorder
- func (m *MockWorker_FetchDDLInfoClient) Header() (metadata.MD, error)
- func (m *MockWorker_FetchDDLInfoClient) Recv() (*pb.DDLInfo, error)
- func (m_2 *MockWorker_FetchDDLInfoClient) RecvMsg(m interface{}) error
- func (m *MockWorker_FetchDDLInfoClient) Send(arg0 *pb.DDLLockInfo) error
- func (m_2 *MockWorker_FetchDDLInfoClient) SendMsg(m interface{}) error
- func (m *MockWorker_FetchDDLInfoClient) Trailer() metadata.MD
- type MockWorker_FetchDDLInfoClientMockRecorder
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Context() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Header() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Recv() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoClientMockRecorder) Trailer() *gomock.Call
- type MockWorker_FetchDDLInfoServer
- func (m *MockWorker_FetchDDLInfoServer) Context() context.Context
- func (m *MockWorker_FetchDDLInfoServer) EXPECT() *MockWorker_FetchDDLInfoServerMockRecorder
- func (m *MockWorker_FetchDDLInfoServer) Recv() (*pb.DDLLockInfo, error)
- func (m_2 *MockWorker_FetchDDLInfoServer) RecvMsg(m interface{}) error
- func (m *MockWorker_FetchDDLInfoServer) Send(arg0 *pb.DDLInfo) error
- func (m *MockWorker_FetchDDLInfoServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockWorker_FetchDDLInfoServer) SendMsg(m interface{}) error
- func (m *MockWorker_FetchDDLInfoServer) SetHeader(arg0 metadata.MD) error
- func (m *MockWorker_FetchDDLInfoServer) SetTrailer(arg0 metadata.MD)
- type MockWorker_FetchDDLInfoServerMockRecorder
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) Context() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) Recv() *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockWorker_FetchDDLInfoServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockisSubTaskError_Error
- type MockisSubTaskError_ErrorMockRecorder
- type MockisSubTaskStatus_Status
- type MockisSubTaskStatus_StatusMockRecorder
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(ctx context.Context, in *pb.BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*pb.BreakWorkerDDLLockResponse, error)
BreakWorkerDDLLock mocks base method
func (*MockMasterClient) CheckTask ¶
func (m *MockMasterClient) CheckTask(ctx context.Context, in *pb.CheckTaskRequest, opts ...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(ctx context.Context, in *pb.HandleSQLsRequest, opts ...grpc.CallOption) (*pb.HandleSQLsResponse, error)
HandleSQLs mocks base method
func (*MockMasterClient) MigrateWorkerRelay ¶
func (m *MockMasterClient) MigrateWorkerRelay(ctx context.Context, in *pb.MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
MigrateWorkerRelay mocks base method
func (*MockMasterClient) OperateTask ¶
func (m *MockMasterClient) OperateTask(ctx context.Context, in *pb.OperateTaskRequest, opts ...grpc.CallOption) (*pb.OperateTaskResponse, error)
OperateTask mocks base method
func (*MockMasterClient) OperateWorkerRelayTask ¶
func (m *MockMasterClient) OperateWorkerRelayTask(ctx context.Context, in *pb.OperateWorkerRelayRequest, opts ...grpc.CallOption) (*pb.OperateWorkerRelayResponse, error)
OperateWorkerRelayTask mocks base method
func (*MockMasterClient) PurgeWorkerRelay ¶
func (m *MockMasterClient) PurgeWorkerRelay(ctx context.Context, in *pb.PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*pb.PurgeWorkerRelayResponse, error)
PurgeWorkerRelay mocks base method
func (*MockMasterClient) QueryError ¶
func (m *MockMasterClient) QueryError(ctx context.Context, in *pb.QueryErrorListRequest, opts ...grpc.CallOption) (*pb.QueryErrorListResponse, error)
QueryError mocks base method
func (*MockMasterClient) QueryStatus ¶
func (m *MockMasterClient) QueryStatus(ctx context.Context, in *pb.QueryStatusListRequest, opts ...grpc.CallOption) (*pb.QueryStatusListResponse, error)
QueryStatus mocks base method
func (*MockMasterClient) RefreshWorkerTasks ¶
func (m *MockMasterClient) RefreshWorkerTasks(ctx context.Context, in *pb.RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*pb.RefreshWorkerTasksResponse, error)
RefreshWorkerTasks mocks base method
func (*MockMasterClient) ShowDDLLocks ¶
func (m *MockMasterClient) ShowDDLLocks(ctx context.Context, in *pb.ShowDDLLocksRequest, opts ...grpc.CallOption) (*pb.ShowDDLLocksResponse, error)
ShowDDLLocks mocks base method
func (*MockMasterClient) StartTask ¶
func (m *MockMasterClient) StartTask(ctx context.Context, in *pb.StartTaskRequest, opts ...grpc.CallOption) (*pb.StartTaskResponse, error)
StartTask mocks base method
func (*MockMasterClient) SwitchWorkerRelayMaster ¶
func (m *MockMasterClient) SwitchWorkerRelayMaster(ctx context.Context, in *pb.SwitchWorkerRelayMasterRequest, opts ...grpc.CallOption) (*pb.SwitchWorkerRelayMasterResponse, error)
SwitchWorkerRelayMaster mocks base method
func (*MockMasterClient) UnlockDDLLock ¶
func (m *MockMasterClient) UnlockDDLLock(ctx context.Context, in *pb.UnlockDDLLockRequest, opts ...grpc.CallOption) (*pb.UnlockDDLLockResponse, error)
UnlockDDLLock mocks base method
func (*MockMasterClient) UpdateMasterConfig ¶
func (m *MockMasterClient) UpdateMasterConfig(ctx context.Context, in *pb.UpdateMasterConfigRequest, opts ...grpc.CallOption) (*pb.UpdateMasterConfigResponse, error)
UpdateMasterConfig mocks base method
func (*MockMasterClient) UpdateTask ¶
func (m *MockMasterClient) UpdateTask(ctx context.Context, in *pb.UpdateTaskRequest, opts ...grpc.CallOption) (*pb.UpdateTaskResponse, error)
UpdateTask mocks base method
func (*MockMasterClient) UpdateWorkerRelayConfig ¶
func (m *MockMasterClient) UpdateWorkerRelayConfig(ctx context.Context, in *pb.UpdateWorkerRelayConfigRequest, opts ...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(ctx, in interface{}, opts ...interface{}) *gomock.Call
BreakWorkerDDLLock indicates an expected call of BreakWorkerDDLLock
func (*MockMasterClientMockRecorder) CheckTask ¶
func (mr *MockMasterClientMockRecorder) CheckTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
CheckTask indicates an expected call of CheckTask
func (*MockMasterClientMockRecorder) HandleSQLs ¶
func (mr *MockMasterClientMockRecorder) HandleSQLs(ctx, in interface{}, opts ...interface{}) *gomock.Call
HandleSQLs indicates an expected call of HandleSQLs
func (*MockMasterClientMockRecorder) MigrateWorkerRelay ¶
func (mr *MockMasterClientMockRecorder) MigrateWorkerRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
MigrateWorkerRelay indicates an expected call of MigrateWorkerRelay
func (*MockMasterClientMockRecorder) OperateTask ¶
func (mr *MockMasterClientMockRecorder) OperateTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
OperateTask indicates an expected call of OperateTask
func (*MockMasterClientMockRecorder) OperateWorkerRelayTask ¶
func (mr *MockMasterClientMockRecorder) OperateWorkerRelayTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
OperateWorkerRelayTask indicates an expected call of OperateWorkerRelayTask
func (*MockMasterClientMockRecorder) PurgeWorkerRelay ¶
func (mr *MockMasterClientMockRecorder) PurgeWorkerRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
PurgeWorkerRelay indicates an expected call of PurgeWorkerRelay
func (*MockMasterClientMockRecorder) QueryError ¶
func (mr *MockMasterClientMockRecorder) QueryError(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryError indicates an expected call of QueryError
func (*MockMasterClientMockRecorder) QueryStatus ¶
func (mr *MockMasterClientMockRecorder) QueryStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryStatus indicates an expected call of QueryStatus
func (*MockMasterClientMockRecorder) RefreshWorkerTasks ¶
func (mr *MockMasterClientMockRecorder) RefreshWorkerTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call
RefreshWorkerTasks indicates an expected call of RefreshWorkerTasks
func (*MockMasterClientMockRecorder) ShowDDLLocks ¶
func (mr *MockMasterClientMockRecorder) ShowDDLLocks(ctx, in interface{}, opts ...interface{}) *gomock.Call
ShowDDLLocks indicates an expected call of ShowDDLLocks
func (*MockMasterClientMockRecorder) StartTask ¶
func (mr *MockMasterClientMockRecorder) StartTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartTask indicates an expected call of StartTask
func (*MockMasterClientMockRecorder) SwitchWorkerRelayMaster ¶
func (mr *MockMasterClientMockRecorder) SwitchWorkerRelayMaster(ctx, in interface{}, opts ...interface{}) *gomock.Call
SwitchWorkerRelayMaster indicates an expected call of SwitchWorkerRelayMaster
func (*MockMasterClientMockRecorder) UnlockDDLLock ¶
func (mr *MockMasterClientMockRecorder) UnlockDDLLock(ctx, in interface{}, opts ...interface{}) *gomock.Call
UnlockDDLLock indicates an expected call of UnlockDDLLock
func (*MockMasterClientMockRecorder) UpdateMasterConfig ¶
func (mr *MockMasterClientMockRecorder) UpdateMasterConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateMasterConfig indicates an expected call of UpdateMasterConfig
func (*MockMasterClientMockRecorder) UpdateTask ¶
func (mr *MockMasterClientMockRecorder) UpdateTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateTask indicates an expected call of UpdateTask
func (*MockMasterClientMockRecorder) UpdateWorkerRelayConfig ¶
func (mr *MockMasterClientMockRecorder) UpdateWorkerRelayConfig(ctx, in interface{}, opts ...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(ctx context.Context, in *pb.BreakDDLLockRequest, opts ...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(ctx context.Context, in *pb.ExecDDLRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
ExecuteDDL mocks base method
func (*MockWorkerClient) FetchDDLInfo ¶
func (m *MockWorkerClient) FetchDDLInfo(ctx context.Context, opts ...grpc.CallOption) (pb.Worker_FetchDDLInfoClient, error)
FetchDDLInfo mocks base method
func (*MockWorkerClient) HandleSQLs ¶
func (m *MockWorkerClient) HandleSQLs(ctx context.Context, in *pb.HandleSubTaskSQLsRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
HandleSQLs mocks base method
func (*MockWorkerClient) MigrateRelay ¶
func (m *MockWorkerClient) MigrateRelay(ctx context.Context, in *pb.MigrateRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
MigrateRelay mocks base method
func (*MockWorkerClient) OperateRelay ¶
func (m *MockWorkerClient) OperateRelay(ctx context.Context, in *pb.OperateRelayRequest, opts ...grpc.CallOption) (*pb.OperateRelayResponse, error)
OperateRelay mocks base method
func (*MockWorkerClient) OperateSubTask ¶
func (m *MockWorkerClient) OperateSubTask(ctx context.Context, in *pb.OperateSubTaskRequest, opts ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)
OperateSubTask mocks base method
func (*MockWorkerClient) PurgeRelay ¶
func (m *MockWorkerClient) PurgeRelay(ctx context.Context, in *pb.PurgeRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
PurgeRelay mocks base method
func (*MockWorkerClient) QueryError ¶
func (m *MockWorkerClient) QueryError(ctx context.Context, in *pb.QueryErrorRequest, opts ...grpc.CallOption) (*pb.QueryErrorResponse, error)
QueryError mocks base method
func (*MockWorkerClient) QueryStatus ¶
func (m *MockWorkerClient) QueryStatus(ctx context.Context, in *pb.QueryStatusRequest, opts ...grpc.CallOption) (*pb.QueryStatusResponse, error)
QueryStatus mocks base method
func (*MockWorkerClient) QueryTaskOperation ¶
func (m *MockWorkerClient) QueryTaskOperation(ctx context.Context, in *pb.QueryTaskOperationRequest, opts ...grpc.CallOption) (*pb.QueryTaskOperationResponse, error)
QueryTaskOperation mocks base method
func (*MockWorkerClient) QueryWorkerConfig ¶
func (m *MockWorkerClient) QueryWorkerConfig(ctx context.Context, in *pb.QueryWorkerConfigRequest, opts ...grpc.CallOption) (*pb.QueryWorkerConfigResponse, error)
QueryWorkerConfig mocks base method
func (*MockWorkerClient) StartSubTask ¶
func (m *MockWorkerClient) StartSubTask(ctx context.Context, in *pb.StartSubTaskRequest, opts ...grpc.CallOption) (*pb.OperateSubTaskResponse, error)
StartSubTask mocks base method
func (*MockWorkerClient) SwitchRelayMaster ¶
func (m *MockWorkerClient) SwitchRelayMaster(ctx context.Context, in *pb.SwitchRelayMasterRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
SwitchRelayMaster mocks base method
func (*MockWorkerClient) UpdateRelayConfig ¶
func (m *MockWorkerClient) UpdateRelayConfig(ctx context.Context, in *pb.UpdateRelayRequest, opts ...grpc.CallOption) (*pb.CommonWorkerResponse, error)
UpdateRelayConfig mocks base method
func (*MockWorkerClient) UpdateSubTask ¶
func (m *MockWorkerClient) UpdateSubTask(ctx context.Context, in *pb.UpdateSubTaskRequest, opts ...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(ctx, in interface{}, opts ...interface{}) *gomock.Call
BreakDDLLock indicates an expected call of BreakDDLLock
func (*MockWorkerClientMockRecorder) ExecuteDDL ¶
func (mr *MockWorkerClientMockRecorder) ExecuteDDL(ctx, in interface{}, opts ...interface{}) *gomock.Call
ExecuteDDL indicates an expected call of ExecuteDDL
func (*MockWorkerClientMockRecorder) FetchDDLInfo ¶
func (mr *MockWorkerClientMockRecorder) FetchDDLInfo(ctx interface{}, opts ...interface{}) *gomock.Call
FetchDDLInfo indicates an expected call of FetchDDLInfo
func (*MockWorkerClientMockRecorder) HandleSQLs ¶
func (mr *MockWorkerClientMockRecorder) HandleSQLs(ctx, in interface{}, opts ...interface{}) *gomock.Call
HandleSQLs indicates an expected call of HandleSQLs
func (*MockWorkerClientMockRecorder) MigrateRelay ¶
func (mr *MockWorkerClientMockRecorder) MigrateRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
MigrateRelay indicates an expected call of MigrateRelay
func (*MockWorkerClientMockRecorder) OperateRelay ¶
func (mr *MockWorkerClientMockRecorder) OperateRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
OperateRelay indicates an expected call of OperateRelay
func (*MockWorkerClientMockRecorder) OperateSubTask ¶
func (mr *MockWorkerClientMockRecorder) OperateSubTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
OperateSubTask indicates an expected call of OperateSubTask
func (*MockWorkerClientMockRecorder) PurgeRelay ¶
func (mr *MockWorkerClientMockRecorder) PurgeRelay(ctx, in interface{}, opts ...interface{}) *gomock.Call
PurgeRelay indicates an expected call of PurgeRelay
func (*MockWorkerClientMockRecorder) QueryError ¶
func (mr *MockWorkerClientMockRecorder) QueryError(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryError indicates an expected call of QueryError
func (*MockWorkerClientMockRecorder) QueryStatus ¶
func (mr *MockWorkerClientMockRecorder) QueryStatus(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryStatus indicates an expected call of QueryStatus
func (*MockWorkerClientMockRecorder) QueryTaskOperation ¶
func (mr *MockWorkerClientMockRecorder) QueryTaskOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryTaskOperation indicates an expected call of QueryTaskOperation
func (*MockWorkerClientMockRecorder) QueryWorkerConfig ¶
func (mr *MockWorkerClientMockRecorder) QueryWorkerConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryWorkerConfig indicates an expected call of QueryWorkerConfig
func (*MockWorkerClientMockRecorder) StartSubTask ¶
func (mr *MockWorkerClientMockRecorder) StartSubTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartSubTask indicates an expected call of StartSubTask
func (*MockWorkerClientMockRecorder) SwitchRelayMaster ¶
func (mr *MockWorkerClientMockRecorder) SwitchRelayMaster(ctx, in interface{}, opts ...interface{}) *gomock.Call
SwitchRelayMaster indicates an expected call of SwitchRelayMaster
func (*MockWorkerClientMockRecorder) UpdateRelayConfig ¶
func (mr *MockWorkerClientMockRecorder) UpdateRelayConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateRelayConfig indicates an expected call of UpdateRelayConfig
func (*MockWorkerClientMockRecorder) UpdateSubTask ¶
func (mr *MockWorkerClientMockRecorder) UpdateSubTask(ctx, in interface{}, opts ...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_2 *MockWorker_FetchDDLInfoClient) RecvMsg(m 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_2 *MockWorker_FetchDDLInfoClient) SendMsg(m 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(m 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(m 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_2 *MockWorker_FetchDDLInfoServer) RecvMsg(m 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_2 *MockWorker_FetchDDLInfoServer) SendMsg(m 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(m 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(m 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
type MockisSubTaskError_Error ¶
type MockisSubTaskError_Error struct {
// contains filtered or unexported fields
}
MockisSubTaskError_Error is a mock of isSubTaskError_Error interface
func NewMockisSubTaskError_Error ¶
func NewMockisSubTaskError_Error(ctrl *gomock.Controller) *MockisSubTaskError_Error
NewMockisSubTaskError_Error creates a new mock instance
func (*MockisSubTaskError_Error) EXPECT ¶
func (m *MockisSubTaskError_Error) EXPECT() *MockisSubTaskError_ErrorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockisSubTaskError_Error) MarshalTo ¶
func (m *MockisSubTaskError_Error) MarshalTo(arg0 []byte) (int, error)
MarshalTo mocks base method
func (*MockisSubTaskError_Error) Size ¶
func (m *MockisSubTaskError_Error) Size() int
Size mocks base method
type MockisSubTaskError_ErrorMockRecorder ¶
type MockisSubTaskError_ErrorMockRecorder struct {
// contains filtered or unexported fields
}
MockisSubTaskError_ErrorMockRecorder is the mock recorder for MockisSubTaskError_Error
func (*MockisSubTaskError_ErrorMockRecorder) MarshalTo ¶
func (mr *MockisSubTaskError_ErrorMockRecorder) MarshalTo(arg0 interface{}) *gomock.Call
MarshalTo indicates an expected call of MarshalTo
func (*MockisSubTaskError_ErrorMockRecorder) Size ¶
func (mr *MockisSubTaskError_ErrorMockRecorder) Size() *gomock.Call
Size indicates an expected call of Size
type MockisSubTaskStatus_Status ¶
type MockisSubTaskStatus_Status struct {
// contains filtered or unexported fields
}
MockisSubTaskStatus_Status is a mock of isSubTaskStatus_Status interface
func NewMockisSubTaskStatus_Status ¶
func NewMockisSubTaskStatus_Status(ctrl *gomock.Controller) *MockisSubTaskStatus_Status
NewMockisSubTaskStatus_Status creates a new mock instance
func (*MockisSubTaskStatus_Status) EXPECT ¶
func (m *MockisSubTaskStatus_Status) EXPECT() *MockisSubTaskStatus_StatusMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockisSubTaskStatus_Status) MarshalTo ¶
func (m *MockisSubTaskStatus_Status) MarshalTo(arg0 []byte) (int, error)
MarshalTo mocks base method
func (*MockisSubTaskStatus_Status) Size ¶
func (m *MockisSubTaskStatus_Status) Size() int
Size mocks base method
type MockisSubTaskStatus_StatusMockRecorder ¶
type MockisSubTaskStatus_StatusMockRecorder struct {
// contains filtered or unexported fields
}
MockisSubTaskStatus_StatusMockRecorder is the mock recorder for MockisSubTaskStatus_Status
func (*MockisSubTaskStatus_StatusMockRecorder) MarshalTo ¶
func (mr *MockisSubTaskStatus_StatusMockRecorder) MarshalTo(arg0 interface{}) *gomock.Call
MarshalTo indicates an expected call of MarshalTo
func (*MockisSubTaskStatus_StatusMockRecorder) Size ¶
func (mr *MockisSubTaskStatus_StatusMockRecorder) Size() *gomock.Call
Size indicates an expected call of Size