pbmock

package
v0.0.0-...-7f57e1f Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2024 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) 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) Encrypt 

func (m *MockMasterClient) Encrypt(arg0 context.Context, arg1 *pb.EncryptRequest, arg2 ...grpc.CallOption) (*pb.EncryptResponse, error)

Encrypt mocks base method.

func (*MockMasterClient) GetCfg 

func (m *MockMasterClient) GetCfg(arg0 context.Context, arg1 *pb.GetCfgRequest, arg2 ...grpc.CallOption) (*pb.GetCfgResponse, error)

GetCfg mocks base method.

func (*MockMasterClient) GetMasterCfg 

func (m *MockMasterClient) GetMasterCfg(arg0 context.Context, arg1 *pb.GetMasterCfgRequest, arg2 ...grpc.CallOption) (*pb.GetMasterCfgResponse, error)

GetMasterCfg mocks base method.

func (*MockMasterClient) GetSubTaskCfg 

func (m *MockMasterClient) GetSubTaskCfg(arg0 context.Context, arg1 *pb.GetSubTaskCfgRequest, arg2 ...grpc.CallOption) (*pb.GetSubTaskCfgResponse, error)

GetSubTaskCfg mocks base method.

func (*MockMasterClient) GetValidationError 

func (m *MockMasterClient) GetValidationError(arg0 context.Context, arg1 *pb.GetValidationErrorRequest, arg2 ...grpc.CallOption) (*pb.GetValidationErrorResponse, error)

GetValidationError mocks base method.

func (*MockMasterClient) GetValidationStatus 

func (m *MockMasterClient) GetValidationStatus(arg0 context.Context, arg1 *pb.GetValidationStatusRequest, arg2 ...grpc.CallOption) (*pb.GetValidationStatusResponse, error)

GetValidationStatus mocks base method.

func (*MockMasterClient) HandleError 

func (m *MockMasterClient) HandleError(arg0 context.Context, arg1 *pb.HandleErrorRequest, arg2 ...grpc.CallOption) (*pb.HandleErrorResponse, error)

HandleError mocks base method.

func (*MockMasterClient) ListMember 

func (m *MockMasterClient) ListMember(arg0 context.Context, arg1 *pb.ListMemberRequest, arg2 ...grpc.CallOption) (*pb.ListMemberResponse, error)

ListMember mocks base method.

func (*MockMasterClient) ListSourceConfigs 

func (m *MockMasterClient) ListSourceConfigs(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*pb.ListSourceConfigsResponse, error)

ListSourceConfigs mocks base method.

func (*MockMasterClient) ListTaskConfigs 

func (m *MockMasterClient) ListTaskConfigs(arg0 context.Context, arg1 *emptypb.Empty, arg2 ...grpc.CallOption) (*pb.ListTaskConfigsResponse, error)

ListTaskConfigs mocks base method.

func (*MockMasterClient) OfflineMember 

func (m *MockMasterClient) OfflineMember(arg0 context.Context, arg1 *pb.OfflineMemberRequest, arg2 ...grpc.CallOption) (*pb.OfflineMemberResponse, error)

OfflineMember mocks base method.

func (*MockMasterClient) OperateLeader 

func (m *MockMasterClient) OperateLeader(arg0 context.Context, arg1 *pb.OperateLeaderRequest, arg2 ...grpc.CallOption) (*pb.OperateLeaderResponse, error)

OperateLeader mocks base method.

func (*MockMasterClient) OperateRelay 

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

OperateRelay mocks base method.

func (*MockMasterClient) OperateSchema 

func (m *MockMasterClient) OperateSchema(arg0 context.Context, arg1 *pb.OperateSchemaRequest, arg2 ...grpc.CallOption) (*pb.OperateSchemaResponse, error)

OperateSchema mocks base method.

func (*MockMasterClient) OperateSource 

func (m *MockMasterClient) OperateSource(arg0 context.Context, arg1 *pb.OperateSourceRequest, arg2 ...grpc.CallOption) (*pb.OperateSourceResponse, error)

OperateSource 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) OperateValidationError 

func (m *MockMasterClient) OperateValidationError(arg0 context.Context, arg1 *pb.OperateValidationErrorRequest, arg2 ...grpc.CallOption) (*pb.OperateValidationErrorResponse, error)

OperateValidationError 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) QueryStatus 

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

QueryStatus mocks base method.

func (*MockMasterClient) RegisterWorker 

func (m *MockMasterClient) RegisterWorker(arg0 context.Context, arg1 *pb.RegisterWorkerRequest, arg2 ...grpc.CallOption) (*pb.RegisterWorkerResponse, error)

RegisterWorker 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) StartValidation 

func (m *MockMasterClient) StartValidation(arg0 context.Context, arg1 *pb.StartValidationRequest, arg2 ...grpc.CallOption) (*pb.StartValidationResponse, error)

StartValidation mocks base method.

func (*MockMasterClient) StopValidation 

func (m *MockMasterClient) StopValidation(arg0 context.Context, arg1 *pb.StopValidationRequest, arg2 ...grpc.CallOption) (*pb.StopValidationResponse, error)

StopValidation mocks base method.

func (*MockMasterClient) TransferSource 

func (m *MockMasterClient) TransferSource(arg0 context.Context, arg1 *pb.TransferSourceRequest, arg2 ...grpc.CallOption) (*pb.TransferSourceResponse, error)

TransferSource 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) UpdateTask 

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

UpdateTask mocks base method.

func (*MockMasterClient) UpdateValidation 

func (m *MockMasterClient) UpdateValidation(arg0 context.Context, arg1 *pb.UpdateValidationRequest, arg2 ...grpc.CallOption) (*pb.UpdateValidationResponse, error)

UpdateValidation mocks base method.

type MockMasterClientMockRecorder 

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

MockMasterClientMockRecorder is the mock recorder for MockMasterClient.

func (*MockMasterClientMockRecorder) CheckTask 

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

CheckTask indicates an expected call of CheckTask.

func (*MockMasterClientMockRecorder) Encrypt 

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

Encrypt indicates an expected call of Encrypt.

func (*MockMasterClientMockRecorder) GetCfg 

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

GetCfg indicates an expected call of GetCfg.

func (*MockMasterClientMockRecorder) GetMasterCfg 

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

GetMasterCfg indicates an expected call of GetMasterCfg.

func (*MockMasterClientMockRecorder) GetSubTaskCfg 

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

GetSubTaskCfg indicates an expected call of GetSubTaskCfg.

func (*MockMasterClientMockRecorder) GetValidationError 

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

GetValidationError indicates an expected call of GetValidationError.

func (*MockMasterClientMockRecorder) GetValidationStatus 

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

GetValidationStatus indicates an expected call of GetValidationStatus.

func (*MockMasterClientMockRecorder) HandleError 

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

HandleError indicates an expected call of HandleError.

func (*MockMasterClientMockRecorder) ListMember 

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

ListMember indicates an expected call of ListMember.

func (*MockMasterClientMockRecorder) ListSourceConfigs 

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

ListSourceConfigs indicates an expected call of ListSourceConfigs.

func (*MockMasterClientMockRecorder) ListTaskConfigs 

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

ListTaskConfigs indicates an expected call of ListTaskConfigs.

func (*MockMasterClientMockRecorder) OfflineMember 

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

OfflineMember indicates an expected call of OfflineMember.

func (*MockMasterClientMockRecorder) OperateLeader 

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

OperateLeader indicates an expected call of OperateLeader.

func (*MockMasterClientMockRecorder) OperateRelay 

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

OperateRelay indicates an expected call of OperateRelay.

func (*MockMasterClientMockRecorder) OperateSchema 

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

OperateSchema indicates an expected call of OperateSchema.

func (*MockMasterClientMockRecorder) OperateSource 

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

OperateSource indicates an expected call of OperateSource.

func (*MockMasterClientMockRecorder) OperateTask 

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

OperateTask indicates an expected call of OperateTask.

func (*MockMasterClientMockRecorder) OperateValidationError 

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

OperateValidationError indicates an expected call of OperateValidationError.

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

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

QueryStatus indicates an expected call of QueryStatus.

func (*MockMasterClientMockRecorder) RegisterWorker 

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

RegisterWorker indicates an expected call of RegisterWorker.

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

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

StartValidation indicates an expected call of StartValidation.

func (*MockMasterClientMockRecorder) StopValidation 

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

StopValidation indicates an expected call of StopValidation.

func (*MockMasterClientMockRecorder) TransferSource 

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

TransferSource indicates an expected call of TransferSource.

func (*MockMasterClientMockRecorder) UnlockDDLLock 

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

UnlockDDLLock indicates an expected call of UnlockDDLLock.

func (*MockMasterClientMockRecorder) UpdateTask 

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

UpdateTask indicates an expected call of UpdateTask.

func (*MockMasterClientMockRecorder) UpdateValidation 

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

UpdateValidation indicates an expected call of UpdateValidation.

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

func (m *MockMasterServer) Encrypt(arg0 context.Context, arg1 *pb.EncryptRequest) (*pb.EncryptResponse, error)

Encrypt mocks base method.

func (*MockMasterServer) GetCfg 

func (m *MockMasterServer) GetCfg(arg0 context.Context, arg1 *pb.GetCfgRequest) (*pb.GetCfgResponse, error)

GetCfg mocks base method.

func (*MockMasterServer) GetMasterCfg 

func (m *MockMasterServer) GetMasterCfg(arg0 context.Context, arg1 *pb.GetMasterCfgRequest) (*pb.GetMasterCfgResponse, error)

GetMasterCfg mocks base method.

func (*MockMasterServer) GetSubTaskCfg 

func (m *MockMasterServer) GetSubTaskCfg(arg0 context.Context, arg1 *pb.GetSubTaskCfgRequest) (*pb.GetSubTaskCfgResponse, error)

GetSubTaskCfg mocks base method.

func (*MockMasterServer) GetValidationError 

func (m *MockMasterServer) GetValidationError(arg0 context.Context, arg1 *pb.GetValidationErrorRequest) (*pb.GetValidationErrorResponse, error)

GetValidationError mocks base method.

func (*MockMasterServer) GetValidationStatus 

func (m *MockMasterServer) GetValidationStatus(arg0 context.Context, arg1 *pb.GetValidationStatusRequest) (*pb.GetValidationStatusResponse, error)

GetValidationStatus mocks base method.

func (*MockMasterServer) HandleError 

func (m *MockMasterServer) HandleError(arg0 context.Context, arg1 *pb.HandleErrorRequest) (*pb.HandleErrorResponse, error)

HandleError mocks base method.

func (*MockMasterServer) ListMember 

func (m *MockMasterServer) ListMember(arg0 context.Context, arg1 *pb.ListMemberRequest) (*pb.ListMemberResponse, error)

ListMember mocks base method.

func (*MockMasterServer) ListSourceConfigs 

func (m *MockMasterServer) ListSourceConfigs(arg0 context.Context, arg1 *emptypb.Empty) (*pb.ListSourceConfigsResponse, error)

ListSourceConfigs mocks base method.

func (*MockMasterServer) ListTaskConfigs 

func (m *MockMasterServer) ListTaskConfigs(arg0 context.Context, arg1 *emptypb.Empty) (*pb.ListTaskConfigsResponse, error)

ListTaskConfigs mocks base method.

func (*MockMasterServer) OfflineMember 

func (m *MockMasterServer) OfflineMember(arg0 context.Context, arg1 *pb.OfflineMemberRequest) (*pb.OfflineMemberResponse, error)

OfflineMember mocks base method.

func (*MockMasterServer) OperateLeader 

func (m *MockMasterServer) OperateLeader(arg0 context.Context, arg1 *pb.OperateLeaderRequest) (*pb.OperateLeaderResponse, error)

OperateLeader mocks base method.

func (*MockMasterServer) OperateRelay 

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

OperateRelay mocks base method.

func (*MockMasterServer) OperateSchema 

func (m *MockMasterServer) OperateSchema(arg0 context.Context, arg1 *pb.OperateSchemaRequest) (*pb.OperateSchemaResponse, error)

OperateSchema mocks base method.

func (*MockMasterServer) OperateSource 

func (m *MockMasterServer) OperateSource(arg0 context.Context, arg1 *pb.OperateSourceRequest) (*pb.OperateSourceResponse, error)

OperateSource 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) OperateValidationError 

func (m *MockMasterServer) OperateValidationError(arg0 context.Context, arg1 *pb.OperateValidationErrorRequest) (*pb.OperateValidationErrorResponse, error)

OperateValidationError 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) QueryStatus 

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

QueryStatus mocks base method.

func (*MockMasterServer) RegisterWorker 

func (m *MockMasterServer) RegisterWorker(arg0 context.Context, arg1 *pb.RegisterWorkerRequest) (*pb.RegisterWorkerResponse, error)

RegisterWorker 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) StartValidation 

func (m *MockMasterServer) StartValidation(arg0 context.Context, arg1 *pb.StartValidationRequest) (*pb.StartValidationResponse, error)

StartValidation mocks base method.

func (*MockMasterServer) StopValidation 

func (m *MockMasterServer) StopValidation(arg0 context.Context, arg1 *pb.StopValidationRequest) (*pb.StopValidationResponse, error)

StopValidation mocks base method.

func (*MockMasterServer) TransferSource 

func (m *MockMasterServer) TransferSource(arg0 context.Context, arg1 *pb.TransferSourceRequest) (*pb.TransferSourceResponse, error)

TransferSource 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) UpdateTask 

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

UpdateTask mocks base method.

func (*MockMasterServer) UpdateValidation 

func (m *MockMasterServer) UpdateValidation(arg0 context.Context, arg1 *pb.UpdateValidationRequest) (*pb.UpdateValidationResponse, error)

UpdateValidation mocks base method.

type MockMasterServerMockRecorder 

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

MockMasterServerMockRecorder is the mock recorder for MockMasterServer.

func (*MockMasterServerMockRecorder) CheckTask 

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

CheckTask indicates an expected call of CheckTask.

func (*MockMasterServerMockRecorder) Encrypt 

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

Encrypt indicates an expected call of Encrypt.

func (*MockMasterServerMockRecorder) GetCfg 

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

GetCfg indicates an expected call of GetCfg.

func (*MockMasterServerMockRecorder) GetMasterCfg 

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

GetMasterCfg indicates an expected call of GetMasterCfg.

func (*MockMasterServerMockRecorder) GetSubTaskCfg 

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

GetSubTaskCfg indicates an expected call of GetSubTaskCfg.

func (*MockMasterServerMockRecorder) GetValidationError 

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

GetValidationError indicates an expected call of GetValidationError.

func (*MockMasterServerMockRecorder) GetValidationStatus 

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

GetValidationStatus indicates an expected call of GetValidationStatus.

func (*MockMasterServerMockRecorder) HandleError 

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

HandleError indicates an expected call of HandleError.

func (*MockMasterServerMockRecorder) ListMember 

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

ListMember indicates an expected call of ListMember.

func (*MockMasterServerMockRecorder) ListSourceConfigs 

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

ListSourceConfigs indicates an expected call of ListSourceConfigs.

func (*MockMasterServerMockRecorder) ListTaskConfigs 

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

ListTaskConfigs indicates an expected call of ListTaskConfigs.

func (*MockMasterServerMockRecorder) OfflineMember 

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

OfflineMember indicates an expected call of OfflineMember.

func (*MockMasterServerMockRecorder) OperateLeader 

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

OperateLeader indicates an expected call of OperateLeader.

func (*MockMasterServerMockRecorder) OperateRelay 

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

OperateRelay indicates an expected call of OperateRelay.

func (*MockMasterServerMockRecorder) OperateSchema 

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

OperateSchema indicates an expected call of OperateSchema.

func (*MockMasterServerMockRecorder) OperateSource 

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

OperateSource indicates an expected call of OperateSource.

func (*MockMasterServerMockRecorder) OperateTask 

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

OperateTask indicates an expected call of OperateTask.

func (*MockMasterServerMockRecorder) OperateValidationError 

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

OperateValidationError indicates an expected call of OperateValidationError.

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

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

QueryStatus indicates an expected call of QueryStatus.

func (*MockMasterServerMockRecorder) RegisterWorker 

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

RegisterWorker indicates an expected call of RegisterWorker.

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

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

StartValidation indicates an expected call of StartValidation.

func (*MockMasterServerMockRecorder) StopValidation 

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

StopValidation indicates an expected call of StopValidation.

func (*MockMasterServerMockRecorder) TransferSource 

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

TransferSource indicates an expected call of TransferSource.

func (*MockMasterServerMockRecorder) UnlockDDLLock 

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

UnlockDDLLock indicates an expected call of UnlockDDLLock.

func (*MockMasterServerMockRecorder) UpdateTask 

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

UpdateTask indicates an expected call of UpdateTask.

func (*MockMasterServerMockRecorder) UpdateValidation 

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

UpdateValidation indicates an expected call of UpdateValidation.

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

func (m *MockWorkerClient) CheckSubtasksCanUpdate(arg0 context.Context, arg1 *pb.CheckSubtasksCanUpdateRequest, arg2 ...grpc.CallOption) (*pb.CheckSubtasksCanUpdateResponse, error)

CheckSubtasksCanUpdate 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) GetValidatorError 

func (m *MockWorkerClient) GetValidatorError(arg0 context.Context, arg1 *pb.GetValidationErrorRequest, arg2 ...grpc.CallOption) (*pb.GetValidationErrorResponse, error)

GetValidatorError mocks base method.

func (*MockWorkerClient) GetWorkerCfg 

func (m *MockWorkerClient) GetWorkerCfg(arg0 context.Context, arg1 *pb.GetWorkerCfgRequest, arg2 ...grpc.CallOption) (*pb.GetWorkerCfgResponse, error)

GetWorkerCfg mocks base method.

func (*MockWorkerClient) GetWorkerValidatorStatus 

func (m *MockWorkerClient) GetWorkerValidatorStatus(arg0 context.Context, arg1 *pb.GetValidationStatusRequest, arg2 ...grpc.CallOption) (*pb.GetValidationStatusResponse, error)

GetWorkerValidatorStatus mocks base method.

func (*MockWorkerClient) HandleError 

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

HandleError mocks base method.

func (*MockWorkerClient) OperateSchema 

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

OperateSchema mocks base method.

func (*MockWorkerClient) OperateV1Meta 

func (m *MockWorkerClient) OperateV1Meta(arg0 context.Context, arg1 *pb.OperateV1MetaRequest, arg2 ...grpc.CallOption) (*pb.OperateV1MetaResponse, error)

OperateV1Meta mocks base method.

func (*MockWorkerClient) OperateValidatorError 

func (m *MockWorkerClient) OperateValidatorError(arg0 context.Context, arg1 *pb.OperateValidationErrorRequest, arg2 ...grpc.CallOption) (*pb.OperateValidationErrorResponse, error)

OperateValidatorError 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) QueryStatus 

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

QueryStatus mocks base method.

func (*MockWorkerClient) UpdateValidator 

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

UpdateValidator mocks base method.

type MockWorkerClientMockRecorder 

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

MockWorkerClientMockRecorder is the mock recorder for MockWorkerClient.

func (*MockWorkerClientMockRecorder) CheckSubtasksCanUpdate 

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

CheckSubtasksCanUpdate indicates an expected call of CheckSubtasksCanUpdate.

func (*MockWorkerClientMockRecorder) GetValidatorError 

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

GetValidatorError indicates an expected call of GetValidatorError.

func (*MockWorkerClientMockRecorder) GetWorkerCfg 

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

GetWorkerCfg indicates an expected call of GetWorkerCfg.

func (*MockWorkerClientMockRecorder) GetWorkerValidatorStatus 

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

GetWorkerValidatorStatus indicates an expected call of GetWorkerValidatorStatus.

func (*MockWorkerClientMockRecorder) HandleError 

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

HandleError indicates an expected call of HandleError.

func (*MockWorkerClientMockRecorder) OperateSchema 

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

OperateSchema indicates an expected call of OperateSchema.

func (*MockWorkerClientMockRecorder) OperateV1Meta 

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

OperateV1Meta indicates an expected call of OperateV1Meta.

func (*MockWorkerClientMockRecorder) OperateValidatorError 

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

OperateValidatorError indicates an expected call of OperateValidatorError.

func (*MockWorkerClientMockRecorder) PurgeRelay 

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

PurgeRelay indicates an expected call of PurgeRelay.

func (*MockWorkerClientMockRecorder) QueryStatus 

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

QueryStatus indicates an expected call of QueryStatus.

func (*MockWorkerClientMockRecorder) UpdateValidator 

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

UpdateValidator indicates an expected call of UpdateValidator.

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

func (m *MockWorkerServer) CheckSubtasksCanUpdate(arg0 context.Context, arg1 *pb.CheckSubtasksCanUpdateRequest) (*pb.CheckSubtasksCanUpdateResponse, error)

CheckSubtasksCanUpdate 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) GetValidatorError 

func (m *MockWorkerServer) GetValidatorError(arg0 context.Context, arg1 *pb.GetValidationErrorRequest) (*pb.GetValidationErrorResponse, error)

GetValidatorError mocks base method.

func (*MockWorkerServer) GetWorkerCfg 

func (m *MockWorkerServer) GetWorkerCfg(arg0 context.Context, arg1 *pb.GetWorkerCfgRequest) (*pb.GetWorkerCfgResponse, error)

GetWorkerCfg mocks base method.

func (*MockWorkerServer) GetWorkerValidatorStatus 

func (m *MockWorkerServer) GetWorkerValidatorStatus(arg0 context.Context, arg1 *pb.GetValidationStatusRequest) (*pb.GetValidationStatusResponse, error)

GetWorkerValidatorStatus mocks base method.

func (*MockWorkerServer) HandleError 

func (m *MockWorkerServer) HandleError(arg0 context.Context, arg1 *pb.HandleWorkerErrorRequest) (*pb.CommonWorkerResponse, error)

HandleError mocks base method.

func (*MockWorkerServer) OperateSchema 

func (m *MockWorkerServer) OperateSchema(arg0 context.Context, arg1 *pb.OperateWorkerSchemaRequest) (*pb.CommonWorkerResponse, error)

OperateSchema mocks base method.

func (*MockWorkerServer) OperateV1Meta 

func (m *MockWorkerServer) OperateV1Meta(arg0 context.Context, arg1 *pb.OperateV1MetaRequest) (*pb.OperateV1MetaResponse, error)

OperateV1Meta mocks base method.

func (*MockWorkerServer) OperateValidatorError 

func (m *MockWorkerServer) OperateValidatorError(arg0 context.Context, arg1 *pb.OperateValidationErrorRequest) (*pb.OperateValidationErrorResponse, error)

OperateValidatorError 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) QueryStatus 

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

QueryStatus mocks base method.

func (*MockWorkerServer) UpdateValidator 

func (m *MockWorkerServer) UpdateValidator(arg0 context.Context, arg1 *pb.UpdateValidationWorkerRequest) (*pb.CommonWorkerResponse, error)

UpdateValidator mocks base method.

type MockWorkerServerMockRecorder 

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

MockWorkerServerMockRecorder is the mock recorder for MockWorkerServer.

func (*MockWorkerServerMockRecorder) CheckSubtasksCanUpdate 

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

CheckSubtasksCanUpdate indicates an expected call of CheckSubtasksCanUpdate.

func (*MockWorkerServerMockRecorder) GetValidatorError 

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

GetValidatorError indicates an expected call of GetValidatorError.

func (*MockWorkerServerMockRecorder) GetWorkerCfg 

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

GetWorkerCfg indicates an expected call of GetWorkerCfg.

func (*MockWorkerServerMockRecorder) GetWorkerValidatorStatus 

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

GetWorkerValidatorStatus indicates an expected call of GetWorkerValidatorStatus.

func (*MockWorkerServerMockRecorder) HandleError 

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

HandleError indicates an expected call of HandleError.

func (*MockWorkerServerMockRecorder) OperateSchema 

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

OperateSchema indicates an expected call of OperateSchema.

func (*MockWorkerServerMockRecorder) OperateV1Meta 

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

OperateV1Meta indicates an expected call of OperateV1Meta.

func (*MockWorkerServerMockRecorder) OperateValidatorError 

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

OperateValidatorError indicates an expected call of OperateValidatorError.

func (*MockWorkerServerMockRecorder) PurgeRelay 

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

PurgeRelay indicates an expected call of PurgeRelay.

func (*MockWorkerServerMockRecorder) QueryStatus 

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

QueryStatus indicates an expected call of QueryStatus.

func (*MockWorkerServerMockRecorder) UpdateValidator 

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

UpdateValidator indicates an expected call of UpdateValidator.

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.