Documentation
¶
Overview ¶
Package mock_idl is a generated GoMock package.
Package mock_idl is a generated GoMock package.
Index ¶
- type MockAgentClient
- func (m *MockAgentClient) AddReplicationEntries(ctx context.Context, in *idl.AddReplicationEntriesRequest, ...) (*idl.AddReplicationEntriesReply, error)
- func (m *MockAgentClient) ArchiveLogDirectory(ctx context.Context, in *idl.ArchiveLogDirectoryRequest, ...) (*idl.ArchiveLogDirectoryReply, error)
- func (m *MockAgentClient) CheckDiskSpace(ctx context.Context, in *idl.CheckSegmentDiskSpaceRequest, ...) (*idl.CheckDiskSpaceReply, error)
- func (m *MockAgentClient) CreateBackupDirectory(ctx context.Context, in *idl.CreateBackupDirectoryRequest, ...) (*idl.CreateBackupDirectoryReply, error)
- func (m *MockAgentClient) CreateRecoveryConf(ctx context.Context, in *idl.CreateRecoveryConfRequest, ...) (*idl.CreateRecoveryConfReply, error)
- func (m *MockAgentClient) DeleteBackupDirectory(ctx context.Context, in *idl.DeleteBackupDirectoryRequest, ...) (*idl.DeleteBackupDirectoryReply, error)
- func (m *MockAgentClient) DeleteDataDirectories(ctx context.Context, in *idl.DeleteDataDirectoriesRequest, ...) (*idl.DeleteDataDirectoriesReply, error)
- func (m *MockAgentClient) DeleteStateDirectory(ctx context.Context, in *idl.DeleteStateDirectoryRequest, ...) (*idl.DeleteStateDirectoryReply, error)
- func (m *MockAgentClient) DeleteTablespaceDirectories(ctx context.Context, in *idl.DeleteTablespaceRequest, opts ...grpc.CallOption) (*idl.DeleteTablespaceReply, error)
- func (m *MockAgentClient) EXPECT() *MockAgentClientMockRecorder
- func (m *MockAgentClient) RenameDirectories(ctx context.Context, in *idl.RenameDirectoriesRequest, opts ...grpc.CallOption) (*idl.RenameDirectoriesReply, error)
- func (m *MockAgentClient) RenameTablespaces(ctx context.Context, in *idl.RenameTablespacesRequest, opts ...grpc.CallOption) (*idl.RenameTablespacesReply, error)
- func (m *MockAgentClient) RestorePrimariesPgControl(ctx context.Context, in *idl.RestorePgControlRequest, opts ...grpc.CallOption) (*idl.RestorePgControlReply, error)
- func (m *MockAgentClient) RsyncDataDirectories(ctx context.Context, in *idl.RsyncRequest, opts ...grpc.CallOption) (*idl.RsyncReply, error)
- func (m *MockAgentClient) RsyncTablespaceDirectories(ctx context.Context, in *idl.RsyncRequest, opts ...grpc.CallOption) (*idl.RsyncReply, error)
- func (m *MockAgentClient) StopAgent(ctx context.Context, in *idl.StopAgentRequest, opts ...grpc.CallOption) (*idl.StopAgentReply, error)
- func (m *MockAgentClient) UpdateConfiguration(ctx context.Context, in *idl.UpdateConfigurationRequest, ...) (*idl.UpdateConfigurationReply, error)
- func (m *MockAgentClient) UpgradePrimaries(ctx context.Context, in *idl.UpgradePrimariesRequest, opts ...grpc.CallOption) (*idl.UpgradePrimariesReply, error)
- type MockAgentClientMockRecorder
- func (mr *MockAgentClientMockRecorder) AddReplicationEntries(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) ArchiveLogDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) CheckDiskSpace(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) CreateBackupDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) CreateRecoveryConf(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) DeleteBackupDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) DeleteDataDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) DeleteStateDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) DeleteTablespaceDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) RenameDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) RenameTablespaces(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) RestorePrimariesPgControl(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) RsyncDataDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) RsyncTablespaceDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) StopAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) UpdateConfiguration(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockAgentClientMockRecorder) UpgradePrimaries(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockAgentServer
- func (m *MockAgentServer) AddReplicationEntries(arg0 context.Context, arg1 *idl.AddReplicationEntriesRequest) (*idl.AddReplicationEntriesReply, error)
- func (m *MockAgentServer) ArchiveLogDirectory(arg0 context.Context, arg1 *idl.ArchiveLogDirectoryRequest) (*idl.ArchiveLogDirectoryReply, error)
- func (m *MockAgentServer) CheckDiskSpace(arg0 context.Context, arg1 *idl.CheckSegmentDiskSpaceRequest) (*idl.CheckDiskSpaceReply, error)
- func (m *MockAgentServer) CreateBackupDirectory(arg0 context.Context, arg1 *idl.CreateBackupDirectoryRequest) (*idl.CreateBackupDirectoryReply, error)
- func (m *MockAgentServer) CreateRecoveryConf(arg0 context.Context, arg1 *idl.CreateRecoveryConfRequest) (*idl.CreateRecoveryConfReply, error)
- func (m *MockAgentServer) DeleteBackupDirectory(arg0 context.Context, arg1 *idl.DeleteBackupDirectoryRequest) (*idl.DeleteBackupDirectoryReply, error)
- func (m *MockAgentServer) DeleteDataDirectories(arg0 context.Context, arg1 *idl.DeleteDataDirectoriesRequest) (*idl.DeleteDataDirectoriesReply, error)
- func (m *MockAgentServer) DeleteStateDirectory(arg0 context.Context, arg1 *idl.DeleteStateDirectoryRequest) (*idl.DeleteStateDirectoryReply, error)
- func (m *MockAgentServer) DeleteTablespaceDirectories(arg0 context.Context, arg1 *idl.DeleteTablespaceRequest) (*idl.DeleteTablespaceReply, error)
- func (m *MockAgentServer) EXPECT() *MockAgentServerMockRecorder
- func (m *MockAgentServer) RenameDirectories(arg0 context.Context, arg1 *idl.RenameDirectoriesRequest) (*idl.RenameDirectoriesReply, error)
- func (m *MockAgentServer) RenameTablespaces(arg0 context.Context, arg1 *idl.RenameTablespacesRequest) (*idl.RenameTablespacesReply, error)
- func (m *MockAgentServer) RestorePrimariesPgControl(arg0 context.Context, arg1 *idl.RestorePgControlRequest) (*idl.RestorePgControlReply, error)
- func (m *MockAgentServer) RsyncDataDirectories(arg0 context.Context, arg1 *idl.RsyncRequest) (*idl.RsyncReply, error)
- func (m *MockAgentServer) RsyncTablespaceDirectories(arg0 context.Context, arg1 *idl.RsyncRequest) (*idl.RsyncReply, error)
- func (m *MockAgentServer) StopAgent(arg0 context.Context, arg1 *idl.StopAgentRequest) (*idl.StopAgentReply, error)
- func (m *MockAgentServer) UpdateConfiguration(arg0 context.Context, arg1 *idl.UpdateConfigurationRequest) (*idl.UpdateConfigurationReply, error)
- func (m *MockAgentServer) UpgradePrimaries(arg0 context.Context, arg1 *idl.UpgradePrimariesRequest) (*idl.UpgradePrimariesReply, error)
- type MockAgentServerMockRecorder
- func (mr *MockAgentServerMockRecorder) AddReplicationEntries(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) ArchiveLogDirectory(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) CheckDiskSpace(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) CreateBackupDirectory(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) CreateRecoveryConf(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) DeleteBackupDirectory(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) DeleteDataDirectories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) DeleteStateDirectory(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) DeleteTablespaceDirectories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) RenameDirectories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) RenameTablespaces(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) RestorePrimariesPgControl(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) RsyncDataDirectories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) RsyncTablespaceDirectories(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) StopAgent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) UpdateConfiguration(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAgentServerMockRecorder) UpgradePrimaries(arg0, arg1 interface{}) *gomock.Call
- type MockCliToHubClient
- func (m *MockCliToHubClient) EXPECT() *MockCliToHubClientMockRecorder
- func (m *MockCliToHubClient) Execute(ctx context.Context, in *idl.ExecuteRequest, opts ...grpc.CallOption) (idl.CliToHub_ExecuteClient, error)
- func (m *MockCliToHubClient) Finalize(ctx context.Context, in *idl.FinalizeRequest, opts ...grpc.CallOption) (idl.CliToHub_FinalizeClient, error)
- func (m *MockCliToHubClient) GetConfig(ctx context.Context, in *idl.GetConfigRequest, opts ...grpc.CallOption) (*idl.GetConfigReply, error)
- func (m *MockCliToHubClient) Initialize(ctx context.Context, in *idl.InitializeRequest, opts ...grpc.CallOption) (idl.CliToHub_InitializeClient, error)
- func (m *MockCliToHubClient) InitializeCreateCluster(ctx context.Context, in *idl.InitializeCreateClusterRequest, ...) (idl.CliToHub_InitializeCreateClusterClient, error)
- func (m *MockCliToHubClient) RestartAgents(ctx context.Context, in *idl.RestartAgentsRequest, opts ...grpc.CallOption) (*idl.RestartAgentsReply, error)
- func (m *MockCliToHubClient) Revert(ctx context.Context, in *idl.RevertRequest, opts ...grpc.CallOption) (idl.CliToHub_RevertClient, error)
- func (m *MockCliToHubClient) StopServices(ctx context.Context, in *idl.StopServicesRequest, opts ...grpc.CallOption) (*idl.StopServicesReply, error)
- type MockCliToHubClientMockRecorder
- func (mr *MockCliToHubClientMockRecorder) Execute(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) Finalize(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) GetConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) Initialize(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) InitializeCreateCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) RestartAgents(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) Revert(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockCliToHubClientMockRecorder) StopServices(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockCliToHubServer
- func (m *MockCliToHubServer) EXPECT() *MockCliToHubServerMockRecorder
- func (m *MockCliToHubServer) Execute(arg0 *idl.ExecuteRequest, arg1 idl.CliToHub_ExecuteServer) error
- func (m *MockCliToHubServer) Finalize(arg0 *idl.FinalizeRequest, arg1 idl.CliToHub_FinalizeServer) error
- func (m *MockCliToHubServer) GetConfig(arg0 context.Context, arg1 *idl.GetConfigRequest) (*idl.GetConfigReply, error)
- func (m *MockCliToHubServer) Initialize(arg0 *idl.InitializeRequest, arg1 idl.CliToHub_InitializeServer) error
- func (m *MockCliToHubServer) InitializeCreateCluster(arg0 *idl.InitializeCreateClusterRequest, ...) error
- func (m *MockCliToHubServer) RestartAgents(arg0 context.Context, arg1 *idl.RestartAgentsRequest) (*idl.RestartAgentsReply, error)
- func (m *MockCliToHubServer) Revert(arg0 *idl.RevertRequest, arg1 idl.CliToHub_RevertServer) error
- func (m *MockCliToHubServer) StopServices(arg0 context.Context, arg1 *idl.StopServicesRequest) (*idl.StopServicesReply, error)
- type MockCliToHubServerMockRecorder
- func (mr *MockCliToHubServerMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) Finalize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) GetConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) Initialize(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) InitializeCreateCluster(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) RestartAgents(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) Revert(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockCliToHubServerMockRecorder) StopServices(arg0, arg1 interface{}) *gomock.Call
- type MockCliToHub_ExecuteClient
- func (m *MockCliToHub_ExecuteClient) CloseSend() error
- func (m *MockCliToHub_ExecuteClient) Context() context.Context
- func (m *MockCliToHub_ExecuteClient) EXPECT() *MockCliToHub_ExecuteClientMockRecorder
- func (m *MockCliToHub_ExecuteClient) Header() (metadata.MD, error)
- func (m *MockCliToHub_ExecuteClient) Recv() (*idl.Message, error)
- func (m_2 *MockCliToHub_ExecuteClient) RecvMsg(m interface{}) error
- func (m_2 *MockCliToHub_ExecuteClient) SendMsg(m interface{}) error
- func (m *MockCliToHub_ExecuteClient) Trailer() metadata.MD
- type MockCliToHub_ExecuteClientMockRecorder
- func (mr *MockCliToHub_ExecuteClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) Header() *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) Recv() *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteClientMockRecorder) Trailer() *gomock.Call
- type MockCliToHub_ExecuteServer
- func (m *MockCliToHub_ExecuteServer) Context() context.Context
- func (m *MockCliToHub_ExecuteServer) EXPECT() *MockCliToHub_ExecuteServerMockRecorder
- func (m_2 *MockCliToHub_ExecuteServer) RecvMsg(m interface{}) error
- func (m *MockCliToHub_ExecuteServer) Send(arg0 *idl.Message) error
- func (m *MockCliToHub_ExecuteServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockCliToHub_ExecuteServer) SendMsg(m interface{}) error
- func (m *MockCliToHub_ExecuteServer) SetHeader(arg0 metadata.MD) error
- func (m *MockCliToHub_ExecuteServer) SetTrailer(arg0 metadata.MD)
- type MockCliToHub_ExecuteServerMockRecorder
- func (mr *MockCliToHub_ExecuteServerMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_ExecuteServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockCliToHub_FinalizeClient
- func (m *MockCliToHub_FinalizeClient) CloseSend() error
- func (m *MockCliToHub_FinalizeClient) Context() context.Context
- func (m *MockCliToHub_FinalizeClient) EXPECT() *MockCliToHub_FinalizeClientMockRecorder
- func (m *MockCliToHub_FinalizeClient) Header() (metadata.MD, error)
- func (m *MockCliToHub_FinalizeClient) Recv() (*idl.Message, error)
- func (m_2 *MockCliToHub_FinalizeClient) RecvMsg(m interface{}) error
- func (m_2 *MockCliToHub_FinalizeClient) SendMsg(m interface{}) error
- func (m *MockCliToHub_FinalizeClient) Trailer() metadata.MD
- type MockCliToHub_FinalizeClientMockRecorder
- func (mr *MockCliToHub_FinalizeClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) Header() *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) Recv() *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeClientMockRecorder) Trailer() *gomock.Call
- type MockCliToHub_FinalizeServer
- func (m *MockCliToHub_FinalizeServer) Context() context.Context
- func (m *MockCliToHub_FinalizeServer) EXPECT() *MockCliToHub_FinalizeServerMockRecorder
- func (m_2 *MockCliToHub_FinalizeServer) RecvMsg(m interface{}) error
- func (m *MockCliToHub_FinalizeServer) Send(arg0 *idl.Message) error
- func (m *MockCliToHub_FinalizeServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockCliToHub_FinalizeServer) SendMsg(m interface{}) error
- func (m *MockCliToHub_FinalizeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockCliToHub_FinalizeServer) SetTrailer(arg0 metadata.MD)
- type MockCliToHub_FinalizeServerMockRecorder
- func (mr *MockCliToHub_FinalizeServerMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_FinalizeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockCliToHub_InitializeClient
- func (m *MockCliToHub_InitializeClient) CloseSend() error
- func (m *MockCliToHub_InitializeClient) Context() context.Context
- func (m *MockCliToHub_InitializeClient) EXPECT() *MockCliToHub_InitializeClientMockRecorder
- func (m *MockCliToHub_InitializeClient) Header() (metadata.MD, error)
- func (m *MockCliToHub_InitializeClient) Recv() (*idl.Message, error)
- func (m_2 *MockCliToHub_InitializeClient) RecvMsg(m interface{}) error
- func (m_2 *MockCliToHub_InitializeClient) SendMsg(m interface{}) error
- func (m *MockCliToHub_InitializeClient) Trailer() metadata.MD
- type MockCliToHub_InitializeClientMockRecorder
- func (mr *MockCliToHub_InitializeClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) Header() *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) Recv() *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeClientMockRecorder) Trailer() *gomock.Call
- type MockCliToHub_InitializeCreateClusterClient
- func (m *MockCliToHub_InitializeCreateClusterClient) CloseSend() error
- func (m *MockCliToHub_InitializeCreateClusterClient) Context() context.Context
- func (m *MockCliToHub_InitializeCreateClusterClient) EXPECT() *MockCliToHub_InitializeCreateClusterClientMockRecorder
- func (m *MockCliToHub_InitializeCreateClusterClient) Header() (metadata.MD, error)
- func (m *MockCliToHub_InitializeCreateClusterClient) Recv() (*idl.Message, error)
- func (m_2 *MockCliToHub_InitializeCreateClusterClient) RecvMsg(m interface{}) error
- func (m_2 *MockCliToHub_InitializeCreateClusterClient) SendMsg(m interface{}) error
- func (m *MockCliToHub_InitializeCreateClusterClient) Trailer() metadata.MD
- type MockCliToHub_InitializeCreateClusterClientMockRecorder
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Header() *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Recv() *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Trailer() *gomock.Call
- type MockCliToHub_InitializeCreateClusterServer
- func (m *MockCliToHub_InitializeCreateClusterServer) Context() context.Context
- func (m *MockCliToHub_InitializeCreateClusterServer) EXPECT() *MockCliToHub_InitializeCreateClusterServerMockRecorder
- func (m_2 *MockCliToHub_InitializeCreateClusterServer) RecvMsg(m interface{}) error
- func (m *MockCliToHub_InitializeCreateClusterServer) Send(arg0 *idl.Message) error
- func (m *MockCliToHub_InitializeCreateClusterServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockCliToHub_InitializeCreateClusterServer) SendMsg(m interface{}) error
- func (m *MockCliToHub_InitializeCreateClusterServer) SetHeader(arg0 metadata.MD) error
- func (m *MockCliToHub_InitializeCreateClusterServer) SetTrailer(arg0 metadata.MD)
- type MockCliToHub_InitializeCreateClusterServerMockRecorder
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockCliToHub_InitializeServer
- func (m *MockCliToHub_InitializeServer) Context() context.Context
- func (m *MockCliToHub_InitializeServer) EXPECT() *MockCliToHub_InitializeServerMockRecorder
- func (m_2 *MockCliToHub_InitializeServer) RecvMsg(m interface{}) error
- func (m *MockCliToHub_InitializeServer) Send(arg0 *idl.Message) error
- func (m *MockCliToHub_InitializeServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockCliToHub_InitializeServer) SendMsg(m interface{}) error
- func (m *MockCliToHub_InitializeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockCliToHub_InitializeServer) SetTrailer(arg0 metadata.MD)
- type MockCliToHub_InitializeServerMockRecorder
- func (mr *MockCliToHub_InitializeServerMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_InitializeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockCliToHub_RevertClient
- func (m *MockCliToHub_RevertClient) CloseSend() error
- func (m *MockCliToHub_RevertClient) Context() context.Context
- func (m *MockCliToHub_RevertClient) EXPECT() *MockCliToHub_RevertClientMockRecorder
- func (m *MockCliToHub_RevertClient) Header() (metadata.MD, error)
- func (m *MockCliToHub_RevertClient) Recv() (*idl.Message, error)
- func (m_2 *MockCliToHub_RevertClient) RecvMsg(m interface{}) error
- func (m_2 *MockCliToHub_RevertClient) SendMsg(m interface{}) error
- func (m *MockCliToHub_RevertClient) Trailer() metadata.MD
- type MockCliToHub_RevertClientMockRecorder
- func (mr *MockCliToHub_RevertClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) Header() *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) Recv() *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertClientMockRecorder) Trailer() *gomock.Call
- type MockCliToHub_RevertServer
- func (m *MockCliToHub_RevertServer) Context() context.Context
- func (m *MockCliToHub_RevertServer) EXPECT() *MockCliToHub_RevertServerMockRecorder
- func (m_2 *MockCliToHub_RevertServer) RecvMsg(m interface{}) error
- func (m *MockCliToHub_RevertServer) Send(arg0 *idl.Message) error
- func (m *MockCliToHub_RevertServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockCliToHub_RevertServer) SendMsg(m interface{}) error
- func (m *MockCliToHub_RevertServer) SetHeader(arg0 metadata.MD) error
- func (m *MockCliToHub_RevertServer) SetTrailer(arg0 metadata.MD)
- type MockCliToHub_RevertServerMockRecorder
- func (mr *MockCliToHub_RevertServerMockRecorder) Context() *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockCliToHub_RevertServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockUnsafeAgentServer
- type MockUnsafeAgentServerMockRecorder
- type MockUnsafeCliToHubServer
- type MockUnsafeCliToHubServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAgentClient ¶
type MockAgentClient struct {
// contains filtered or unexported fields
}
MockAgentClient is a mock of AgentClient interface.
func NewMockAgentClient ¶
func NewMockAgentClient(ctrl *gomock.Controller) *MockAgentClient
NewMockAgentClient creates a new mock instance.
func (*MockAgentClient) AddReplicationEntries ¶
func (m *MockAgentClient) AddReplicationEntries(ctx context.Context, in *idl.AddReplicationEntriesRequest, opts ...grpc.CallOption) (*idl.AddReplicationEntriesReply, error)
AddReplicationEntries mocks base method.
func (*MockAgentClient) ArchiveLogDirectory ¶
func (m *MockAgentClient) ArchiveLogDirectory(ctx context.Context, in *idl.ArchiveLogDirectoryRequest, opts ...grpc.CallOption) (*idl.ArchiveLogDirectoryReply, error)
ArchiveLogDirectory mocks base method.
func (*MockAgentClient) CheckDiskSpace ¶
func (m *MockAgentClient) CheckDiskSpace(ctx context.Context, in *idl.CheckSegmentDiskSpaceRequest, opts ...grpc.CallOption) (*idl.CheckDiskSpaceReply, error)
CheckDiskSpace mocks base method.
func (*MockAgentClient) CreateBackupDirectory ¶
func (m *MockAgentClient) CreateBackupDirectory(ctx context.Context, in *idl.CreateBackupDirectoryRequest, opts ...grpc.CallOption) (*idl.CreateBackupDirectoryReply, error)
CreateBackupDirectory mocks base method.
func (*MockAgentClient) CreateRecoveryConf ¶
func (m *MockAgentClient) CreateRecoveryConf(ctx context.Context, in *idl.CreateRecoveryConfRequest, opts ...grpc.CallOption) (*idl.CreateRecoveryConfReply, error)
CreateRecoveryConf mocks base method.
func (*MockAgentClient) DeleteBackupDirectory ¶
func (m *MockAgentClient) DeleteBackupDirectory(ctx context.Context, in *idl.DeleteBackupDirectoryRequest, opts ...grpc.CallOption) (*idl.DeleteBackupDirectoryReply, error)
DeleteBackupDirectory mocks base method.
func (*MockAgentClient) DeleteDataDirectories ¶
func (m *MockAgentClient) DeleteDataDirectories(ctx context.Context, in *idl.DeleteDataDirectoriesRequest, opts ...grpc.CallOption) (*idl.DeleteDataDirectoriesReply, error)
DeleteDataDirectories mocks base method.
func (*MockAgentClient) DeleteStateDirectory ¶
func (m *MockAgentClient) DeleteStateDirectory(ctx context.Context, in *idl.DeleteStateDirectoryRequest, opts ...grpc.CallOption) (*idl.DeleteStateDirectoryReply, error)
DeleteStateDirectory mocks base method.
func (*MockAgentClient) DeleteTablespaceDirectories ¶
func (m *MockAgentClient) DeleteTablespaceDirectories(ctx context.Context, in *idl.DeleteTablespaceRequest, opts ...grpc.CallOption) (*idl.DeleteTablespaceReply, error)
DeleteTablespaceDirectories mocks base method.
func (*MockAgentClient) EXPECT ¶
func (m *MockAgentClient) EXPECT() *MockAgentClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentClient) RenameDirectories ¶
func (m *MockAgentClient) RenameDirectories(ctx context.Context, in *idl.RenameDirectoriesRequest, opts ...grpc.CallOption) (*idl.RenameDirectoriesReply, error)
RenameDirectories mocks base method.
func (*MockAgentClient) RenameTablespaces ¶
func (m *MockAgentClient) RenameTablespaces(ctx context.Context, in *idl.RenameTablespacesRequest, opts ...grpc.CallOption) (*idl.RenameTablespacesReply, error)
RenameTablespaces mocks base method.
func (*MockAgentClient) RestorePrimariesPgControl ¶
func (m *MockAgentClient) RestorePrimariesPgControl(ctx context.Context, in *idl.RestorePgControlRequest, opts ...grpc.CallOption) (*idl.RestorePgControlReply, error)
RestorePrimariesPgControl mocks base method.
func (*MockAgentClient) RsyncDataDirectories ¶
func (m *MockAgentClient) RsyncDataDirectories(ctx context.Context, in *idl.RsyncRequest, opts ...grpc.CallOption) (*idl.RsyncReply, error)
RsyncDataDirectories mocks base method.
func (*MockAgentClient) RsyncTablespaceDirectories ¶
func (m *MockAgentClient) RsyncTablespaceDirectories(ctx context.Context, in *idl.RsyncRequest, opts ...grpc.CallOption) (*idl.RsyncReply, error)
RsyncTablespaceDirectories mocks base method.
func (*MockAgentClient) StopAgent ¶
func (m *MockAgentClient) StopAgent(ctx context.Context, in *idl.StopAgentRequest, opts ...grpc.CallOption) (*idl.StopAgentReply, error)
StopAgent mocks base method.
func (*MockAgentClient) UpdateConfiguration ¶
func (m *MockAgentClient) UpdateConfiguration(ctx context.Context, in *idl.UpdateConfigurationRequest, opts ...grpc.CallOption) (*idl.UpdateConfigurationReply, error)
UpdateConfiguration mocks base method.
func (*MockAgentClient) UpgradePrimaries ¶
func (m *MockAgentClient) UpgradePrimaries(ctx context.Context, in *idl.UpgradePrimariesRequest, opts ...grpc.CallOption) (*idl.UpgradePrimariesReply, error)
UpgradePrimaries mocks base method.
type MockAgentClientMockRecorder ¶
type MockAgentClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentClientMockRecorder is the mock recorder for MockAgentClient.
func (*MockAgentClientMockRecorder) AddReplicationEntries ¶
func (mr *MockAgentClientMockRecorder) AddReplicationEntries(ctx, in interface{}, opts ...interface{}) *gomock.Call
AddReplicationEntries indicates an expected call of AddReplicationEntries.
func (*MockAgentClientMockRecorder) ArchiveLogDirectory ¶
func (mr *MockAgentClientMockRecorder) ArchiveLogDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
ArchiveLogDirectory indicates an expected call of ArchiveLogDirectory.
func (*MockAgentClientMockRecorder) CheckDiskSpace ¶
func (mr *MockAgentClientMockRecorder) CheckDiskSpace(ctx, in interface{}, opts ...interface{}) *gomock.Call
CheckDiskSpace indicates an expected call of CheckDiskSpace.
func (*MockAgentClientMockRecorder) CreateBackupDirectory ¶
func (mr *MockAgentClientMockRecorder) CreateBackupDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
CreateBackupDirectory indicates an expected call of CreateBackupDirectory.
func (*MockAgentClientMockRecorder) CreateRecoveryConf ¶
func (mr *MockAgentClientMockRecorder) CreateRecoveryConf(ctx, in interface{}, opts ...interface{}) *gomock.Call
CreateRecoveryConf indicates an expected call of CreateRecoveryConf.
func (*MockAgentClientMockRecorder) DeleteBackupDirectory ¶
func (mr *MockAgentClientMockRecorder) DeleteBackupDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteBackupDirectory indicates an expected call of DeleteBackupDirectory.
func (*MockAgentClientMockRecorder) DeleteDataDirectories ¶
func (mr *MockAgentClientMockRecorder) DeleteDataDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteDataDirectories indicates an expected call of DeleteDataDirectories.
func (*MockAgentClientMockRecorder) DeleteStateDirectory ¶
func (mr *MockAgentClientMockRecorder) DeleteStateDirectory(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteStateDirectory indicates an expected call of DeleteStateDirectory.
func (*MockAgentClientMockRecorder) DeleteTablespaceDirectories ¶
func (mr *MockAgentClientMockRecorder) DeleteTablespaceDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteTablespaceDirectories indicates an expected call of DeleteTablespaceDirectories.
func (*MockAgentClientMockRecorder) RenameDirectories ¶
func (mr *MockAgentClientMockRecorder) RenameDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
RenameDirectories indicates an expected call of RenameDirectories.
func (*MockAgentClientMockRecorder) RenameTablespaces ¶
func (mr *MockAgentClientMockRecorder) RenameTablespaces(ctx, in interface{}, opts ...interface{}) *gomock.Call
RenameTablespaces indicates an expected call of RenameTablespaces.
func (*MockAgentClientMockRecorder) RestorePrimariesPgControl ¶
func (mr *MockAgentClientMockRecorder) RestorePrimariesPgControl(ctx, in interface{}, opts ...interface{}) *gomock.Call
RestorePrimariesPgControl indicates an expected call of RestorePrimariesPgControl.
func (*MockAgentClientMockRecorder) RsyncDataDirectories ¶
func (mr *MockAgentClientMockRecorder) RsyncDataDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
RsyncDataDirectories indicates an expected call of RsyncDataDirectories.
func (*MockAgentClientMockRecorder) RsyncTablespaceDirectories ¶
func (mr *MockAgentClientMockRecorder) RsyncTablespaceDirectories(ctx, in interface{}, opts ...interface{}) *gomock.Call
RsyncTablespaceDirectories indicates an expected call of RsyncTablespaceDirectories.
func (*MockAgentClientMockRecorder) StopAgent ¶
func (mr *MockAgentClientMockRecorder) StopAgent(ctx, in interface{}, opts ...interface{}) *gomock.Call
StopAgent indicates an expected call of StopAgent.
func (*MockAgentClientMockRecorder) UpdateConfiguration ¶
func (mr *MockAgentClientMockRecorder) UpdateConfiguration(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateConfiguration indicates an expected call of UpdateConfiguration.
func (*MockAgentClientMockRecorder) UpgradePrimaries ¶
func (mr *MockAgentClientMockRecorder) UpgradePrimaries(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpgradePrimaries indicates an expected call of UpgradePrimaries.
type MockAgentServer ¶
type MockAgentServer struct {
// contains filtered or unexported fields
}
MockAgentServer is a mock of AgentServer interface.
func NewMockAgentServer ¶
func NewMockAgentServer(ctrl *gomock.Controller) *MockAgentServer
NewMockAgentServer creates a new mock instance.
func (*MockAgentServer) AddReplicationEntries ¶
func (m *MockAgentServer) AddReplicationEntries(arg0 context.Context, arg1 *idl.AddReplicationEntriesRequest) (*idl.AddReplicationEntriesReply, error)
AddReplicationEntries mocks base method.
func (*MockAgentServer) ArchiveLogDirectory ¶
func (m *MockAgentServer) ArchiveLogDirectory(arg0 context.Context, arg1 *idl.ArchiveLogDirectoryRequest) (*idl.ArchiveLogDirectoryReply, error)
ArchiveLogDirectory mocks base method.
func (*MockAgentServer) CheckDiskSpace ¶
func (m *MockAgentServer) CheckDiskSpace(arg0 context.Context, arg1 *idl.CheckSegmentDiskSpaceRequest) (*idl.CheckDiskSpaceReply, error)
CheckDiskSpace mocks base method.
func (*MockAgentServer) CreateBackupDirectory ¶
func (m *MockAgentServer) CreateBackupDirectory(arg0 context.Context, arg1 *idl.CreateBackupDirectoryRequest) (*idl.CreateBackupDirectoryReply, error)
CreateBackupDirectory mocks base method.
func (*MockAgentServer) CreateRecoveryConf ¶
func (m *MockAgentServer) CreateRecoveryConf(arg0 context.Context, arg1 *idl.CreateRecoveryConfRequest) (*idl.CreateRecoveryConfReply, error)
CreateRecoveryConf mocks base method.
func (*MockAgentServer) DeleteBackupDirectory ¶
func (m *MockAgentServer) DeleteBackupDirectory(arg0 context.Context, arg1 *idl.DeleteBackupDirectoryRequest) (*idl.DeleteBackupDirectoryReply, error)
DeleteBackupDirectory mocks base method.
func (*MockAgentServer) DeleteDataDirectories ¶
func (m *MockAgentServer) DeleteDataDirectories(arg0 context.Context, arg1 *idl.DeleteDataDirectoriesRequest) (*idl.DeleteDataDirectoriesReply, error)
DeleteDataDirectories mocks base method.
func (*MockAgentServer) DeleteStateDirectory ¶
func (m *MockAgentServer) DeleteStateDirectory(arg0 context.Context, arg1 *idl.DeleteStateDirectoryRequest) (*idl.DeleteStateDirectoryReply, error)
DeleteStateDirectory mocks base method.
func (*MockAgentServer) DeleteTablespaceDirectories ¶
func (m *MockAgentServer) DeleteTablespaceDirectories(arg0 context.Context, arg1 *idl.DeleteTablespaceRequest) (*idl.DeleteTablespaceReply, error)
DeleteTablespaceDirectories mocks base method.
func (*MockAgentServer) EXPECT ¶
func (m *MockAgentServer) EXPECT() *MockAgentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentServer) RenameDirectories ¶
func (m *MockAgentServer) RenameDirectories(arg0 context.Context, arg1 *idl.RenameDirectoriesRequest) (*idl.RenameDirectoriesReply, error)
RenameDirectories mocks base method.
func (*MockAgentServer) RenameTablespaces ¶
func (m *MockAgentServer) RenameTablespaces(arg0 context.Context, arg1 *idl.RenameTablespacesRequest) (*idl.RenameTablespacesReply, error)
RenameTablespaces mocks base method.
func (*MockAgentServer) RestorePrimariesPgControl ¶
func (m *MockAgentServer) RestorePrimariesPgControl(arg0 context.Context, arg1 *idl.RestorePgControlRequest) (*idl.RestorePgControlReply, error)
RestorePrimariesPgControl mocks base method.
func (*MockAgentServer) RsyncDataDirectories ¶
func (m *MockAgentServer) RsyncDataDirectories(arg0 context.Context, arg1 *idl.RsyncRequest) (*idl.RsyncReply, error)
RsyncDataDirectories mocks base method.
func (*MockAgentServer) RsyncTablespaceDirectories ¶
func (m *MockAgentServer) RsyncTablespaceDirectories(arg0 context.Context, arg1 *idl.RsyncRequest) (*idl.RsyncReply, error)
RsyncTablespaceDirectories mocks base method.
func (*MockAgentServer) StopAgent ¶
func (m *MockAgentServer) StopAgent(arg0 context.Context, arg1 *idl.StopAgentRequest) (*idl.StopAgentReply, error)
StopAgent mocks base method.
func (*MockAgentServer) UpdateConfiguration ¶
func (m *MockAgentServer) UpdateConfiguration(arg0 context.Context, arg1 *idl.UpdateConfigurationRequest) (*idl.UpdateConfigurationReply, error)
UpdateConfiguration mocks base method.
func (*MockAgentServer) UpgradePrimaries ¶
func (m *MockAgentServer) UpgradePrimaries(arg0 context.Context, arg1 *idl.UpgradePrimariesRequest) (*idl.UpgradePrimariesReply, error)
UpgradePrimaries mocks base method.
type MockAgentServerMockRecorder ¶
type MockAgentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentServerMockRecorder is the mock recorder for MockAgentServer.
func (*MockAgentServerMockRecorder) AddReplicationEntries ¶
func (mr *MockAgentServerMockRecorder) AddReplicationEntries(arg0, arg1 interface{}) *gomock.Call
AddReplicationEntries indicates an expected call of AddReplicationEntries.
func (*MockAgentServerMockRecorder) ArchiveLogDirectory ¶
func (mr *MockAgentServerMockRecorder) ArchiveLogDirectory(arg0, arg1 interface{}) *gomock.Call
ArchiveLogDirectory indicates an expected call of ArchiveLogDirectory.
func (*MockAgentServerMockRecorder) CheckDiskSpace ¶
func (mr *MockAgentServerMockRecorder) CheckDiskSpace(arg0, arg1 interface{}) *gomock.Call
CheckDiskSpace indicates an expected call of CheckDiskSpace.
func (*MockAgentServerMockRecorder) CreateBackupDirectory ¶
func (mr *MockAgentServerMockRecorder) CreateBackupDirectory(arg0, arg1 interface{}) *gomock.Call
CreateBackupDirectory indicates an expected call of CreateBackupDirectory.
func (*MockAgentServerMockRecorder) CreateRecoveryConf ¶
func (mr *MockAgentServerMockRecorder) CreateRecoveryConf(arg0, arg1 interface{}) *gomock.Call
CreateRecoveryConf indicates an expected call of CreateRecoveryConf.
func (*MockAgentServerMockRecorder) DeleteBackupDirectory ¶
func (mr *MockAgentServerMockRecorder) DeleteBackupDirectory(arg0, arg1 interface{}) *gomock.Call
DeleteBackupDirectory indicates an expected call of DeleteBackupDirectory.
func (*MockAgentServerMockRecorder) DeleteDataDirectories ¶
func (mr *MockAgentServerMockRecorder) DeleteDataDirectories(arg0, arg1 interface{}) *gomock.Call
DeleteDataDirectories indicates an expected call of DeleteDataDirectories.
func (*MockAgentServerMockRecorder) DeleteStateDirectory ¶
func (mr *MockAgentServerMockRecorder) DeleteStateDirectory(arg0, arg1 interface{}) *gomock.Call
DeleteStateDirectory indicates an expected call of DeleteStateDirectory.
func (*MockAgentServerMockRecorder) DeleteTablespaceDirectories ¶
func (mr *MockAgentServerMockRecorder) DeleteTablespaceDirectories(arg0, arg1 interface{}) *gomock.Call
DeleteTablespaceDirectories indicates an expected call of DeleteTablespaceDirectories.
func (*MockAgentServerMockRecorder) RenameDirectories ¶
func (mr *MockAgentServerMockRecorder) RenameDirectories(arg0, arg1 interface{}) *gomock.Call
RenameDirectories indicates an expected call of RenameDirectories.
func (*MockAgentServerMockRecorder) RenameTablespaces ¶
func (mr *MockAgentServerMockRecorder) RenameTablespaces(arg0, arg1 interface{}) *gomock.Call
RenameTablespaces indicates an expected call of RenameTablespaces.
func (*MockAgentServerMockRecorder) RestorePrimariesPgControl ¶
func (mr *MockAgentServerMockRecorder) RestorePrimariesPgControl(arg0, arg1 interface{}) *gomock.Call
RestorePrimariesPgControl indicates an expected call of RestorePrimariesPgControl.
func (*MockAgentServerMockRecorder) RsyncDataDirectories ¶
func (mr *MockAgentServerMockRecorder) RsyncDataDirectories(arg0, arg1 interface{}) *gomock.Call
RsyncDataDirectories indicates an expected call of RsyncDataDirectories.
func (*MockAgentServerMockRecorder) RsyncTablespaceDirectories ¶
func (mr *MockAgentServerMockRecorder) RsyncTablespaceDirectories(arg0, arg1 interface{}) *gomock.Call
RsyncTablespaceDirectories indicates an expected call of RsyncTablespaceDirectories.
func (*MockAgentServerMockRecorder) StopAgent ¶
func (mr *MockAgentServerMockRecorder) StopAgent(arg0, arg1 interface{}) *gomock.Call
StopAgent indicates an expected call of StopAgent.
func (*MockAgentServerMockRecorder) UpdateConfiguration ¶
func (mr *MockAgentServerMockRecorder) UpdateConfiguration(arg0, arg1 interface{}) *gomock.Call
UpdateConfiguration indicates an expected call of UpdateConfiguration.
func (*MockAgentServerMockRecorder) UpgradePrimaries ¶
func (mr *MockAgentServerMockRecorder) UpgradePrimaries(arg0, arg1 interface{}) *gomock.Call
UpgradePrimaries indicates an expected call of UpgradePrimaries.
type MockCliToHubClient ¶
type MockCliToHubClient struct {
// contains filtered or unexported fields
}
MockCliToHubClient is a mock of CliToHubClient interface.
func NewMockCliToHubClient ¶
func NewMockCliToHubClient(ctrl *gomock.Controller) *MockCliToHubClient
NewMockCliToHubClient creates a new mock instance.
func (*MockCliToHubClient) EXPECT ¶
func (m *MockCliToHubClient) EXPECT() *MockCliToHubClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHubClient) Execute ¶
func (m *MockCliToHubClient) Execute(ctx context.Context, in *idl.ExecuteRequest, opts ...grpc.CallOption) (idl.CliToHub_ExecuteClient, error)
Execute mocks base method.
func (*MockCliToHubClient) Finalize ¶
func (m *MockCliToHubClient) Finalize(ctx context.Context, in *idl.FinalizeRequest, opts ...grpc.CallOption) (idl.CliToHub_FinalizeClient, error)
Finalize mocks base method.
func (*MockCliToHubClient) GetConfig ¶
func (m *MockCliToHubClient) GetConfig(ctx context.Context, in *idl.GetConfigRequest, opts ...grpc.CallOption) (*idl.GetConfigReply, error)
GetConfig mocks base method.
func (*MockCliToHubClient) Initialize ¶
func (m *MockCliToHubClient) Initialize(ctx context.Context, in *idl.InitializeRequest, opts ...grpc.CallOption) (idl.CliToHub_InitializeClient, error)
Initialize mocks base method.
func (*MockCliToHubClient) InitializeCreateCluster ¶
func (m *MockCliToHubClient) InitializeCreateCluster(ctx context.Context, in *idl.InitializeCreateClusterRequest, opts ...grpc.CallOption) (idl.CliToHub_InitializeCreateClusterClient, error)
InitializeCreateCluster mocks base method.
func (*MockCliToHubClient) RestartAgents ¶
func (m *MockCliToHubClient) RestartAgents(ctx context.Context, in *idl.RestartAgentsRequest, opts ...grpc.CallOption) (*idl.RestartAgentsReply, error)
RestartAgents mocks base method.
func (*MockCliToHubClient) Revert ¶
func (m *MockCliToHubClient) Revert(ctx context.Context, in *idl.RevertRequest, opts ...grpc.CallOption) (idl.CliToHub_RevertClient, error)
Revert mocks base method.
func (*MockCliToHubClient) StopServices ¶
func (m *MockCliToHubClient) StopServices(ctx context.Context, in *idl.StopServicesRequest, opts ...grpc.CallOption) (*idl.StopServicesReply, error)
StopServices mocks base method.
type MockCliToHubClientMockRecorder ¶
type MockCliToHubClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHubClientMockRecorder is the mock recorder for MockCliToHubClient.
func (*MockCliToHubClientMockRecorder) Execute ¶
func (mr *MockCliToHubClientMockRecorder) Execute(ctx, in interface{}, opts ...interface{}) *gomock.Call
Execute indicates an expected call of Execute.
func (*MockCliToHubClientMockRecorder) Finalize ¶
func (mr *MockCliToHubClientMockRecorder) Finalize(ctx, in interface{}, opts ...interface{}) *gomock.Call
Finalize indicates an expected call of Finalize.
func (*MockCliToHubClientMockRecorder) GetConfig ¶
func (mr *MockCliToHubClientMockRecorder) GetConfig(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockCliToHubClientMockRecorder) Initialize ¶
func (mr *MockCliToHubClientMockRecorder) Initialize(ctx, in interface{}, opts ...interface{}) *gomock.Call
Initialize indicates an expected call of Initialize.
func (*MockCliToHubClientMockRecorder) InitializeCreateCluster ¶
func (mr *MockCliToHubClientMockRecorder) InitializeCreateCluster(ctx, in interface{}, opts ...interface{}) *gomock.Call
InitializeCreateCluster indicates an expected call of InitializeCreateCluster.
func (*MockCliToHubClientMockRecorder) RestartAgents ¶
func (mr *MockCliToHubClientMockRecorder) RestartAgents(ctx, in interface{}, opts ...interface{}) *gomock.Call
RestartAgents indicates an expected call of RestartAgents.
func (*MockCliToHubClientMockRecorder) Revert ¶
func (mr *MockCliToHubClientMockRecorder) Revert(ctx, in interface{}, opts ...interface{}) *gomock.Call
Revert indicates an expected call of Revert.
func (*MockCliToHubClientMockRecorder) StopServices ¶
func (mr *MockCliToHubClientMockRecorder) StopServices(ctx, in interface{}, opts ...interface{}) *gomock.Call
StopServices indicates an expected call of StopServices.
type MockCliToHubServer ¶
type MockCliToHubServer struct {
// contains filtered or unexported fields
}
MockCliToHubServer is a mock of CliToHubServer interface.
func NewMockCliToHubServer ¶
func NewMockCliToHubServer(ctrl *gomock.Controller) *MockCliToHubServer
NewMockCliToHubServer creates a new mock instance.
func (*MockCliToHubServer) EXPECT ¶
func (m *MockCliToHubServer) EXPECT() *MockCliToHubServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHubServer) Execute ¶
func (m *MockCliToHubServer) Execute(arg0 *idl.ExecuteRequest, arg1 idl.CliToHub_ExecuteServer) error
Execute mocks base method.
func (*MockCliToHubServer) Finalize ¶
func (m *MockCliToHubServer) Finalize(arg0 *idl.FinalizeRequest, arg1 idl.CliToHub_FinalizeServer) error
Finalize mocks base method.
func (*MockCliToHubServer) GetConfig ¶
func (m *MockCliToHubServer) GetConfig(arg0 context.Context, arg1 *idl.GetConfigRequest) (*idl.GetConfigReply, error)
GetConfig mocks base method.
func (*MockCliToHubServer) Initialize ¶
func (m *MockCliToHubServer) Initialize(arg0 *idl.InitializeRequest, arg1 idl.CliToHub_InitializeServer) error
Initialize mocks base method.
func (*MockCliToHubServer) InitializeCreateCluster ¶
func (m *MockCliToHubServer) InitializeCreateCluster(arg0 *idl.InitializeCreateClusterRequest, arg1 idl.CliToHub_InitializeCreateClusterServer) error
InitializeCreateCluster mocks base method.
func (*MockCliToHubServer) RestartAgents ¶
func (m *MockCliToHubServer) RestartAgents(arg0 context.Context, arg1 *idl.RestartAgentsRequest) (*idl.RestartAgentsReply, error)
RestartAgents mocks base method.
func (*MockCliToHubServer) Revert ¶
func (m *MockCliToHubServer) Revert(arg0 *idl.RevertRequest, arg1 idl.CliToHub_RevertServer) error
Revert mocks base method.
func (*MockCliToHubServer) StopServices ¶
func (m *MockCliToHubServer) StopServices(arg0 context.Context, arg1 *idl.StopServicesRequest) (*idl.StopServicesReply, error)
StopServices mocks base method.
type MockCliToHubServerMockRecorder ¶
type MockCliToHubServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHubServerMockRecorder is the mock recorder for MockCliToHubServer.
func (*MockCliToHubServerMockRecorder) Execute ¶
func (mr *MockCliToHubServerMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call
Execute indicates an expected call of Execute.
func (*MockCliToHubServerMockRecorder) Finalize ¶
func (mr *MockCliToHubServerMockRecorder) Finalize(arg0, arg1 interface{}) *gomock.Call
Finalize indicates an expected call of Finalize.
func (*MockCliToHubServerMockRecorder) GetConfig ¶
func (mr *MockCliToHubServerMockRecorder) GetConfig(arg0, arg1 interface{}) *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockCliToHubServerMockRecorder) Initialize ¶
func (mr *MockCliToHubServerMockRecorder) Initialize(arg0, arg1 interface{}) *gomock.Call
Initialize indicates an expected call of Initialize.
func (*MockCliToHubServerMockRecorder) InitializeCreateCluster ¶
func (mr *MockCliToHubServerMockRecorder) InitializeCreateCluster(arg0, arg1 interface{}) *gomock.Call
InitializeCreateCluster indicates an expected call of InitializeCreateCluster.
func (*MockCliToHubServerMockRecorder) RestartAgents ¶
func (mr *MockCliToHubServerMockRecorder) RestartAgents(arg0, arg1 interface{}) *gomock.Call
RestartAgents indicates an expected call of RestartAgents.
func (*MockCliToHubServerMockRecorder) Revert ¶
func (mr *MockCliToHubServerMockRecorder) Revert(arg0, arg1 interface{}) *gomock.Call
Revert indicates an expected call of Revert.
func (*MockCliToHubServerMockRecorder) StopServices ¶
func (mr *MockCliToHubServerMockRecorder) StopServices(arg0, arg1 interface{}) *gomock.Call
StopServices indicates an expected call of StopServices.
type MockCliToHub_ExecuteClient ¶
type MockCliToHub_ExecuteClient struct {
// contains filtered or unexported fields
}
MockCliToHub_ExecuteClient is a mock of CliToHub_ExecuteClient interface.
func NewMockCliToHub_ExecuteClient ¶
func NewMockCliToHub_ExecuteClient(ctrl *gomock.Controller) *MockCliToHub_ExecuteClient
NewMockCliToHub_ExecuteClient creates a new mock instance.
func (*MockCliToHub_ExecuteClient) CloseSend ¶
func (m *MockCliToHub_ExecuteClient) CloseSend() error
CloseSend mocks base method.
func (*MockCliToHub_ExecuteClient) Context ¶
func (m *MockCliToHub_ExecuteClient) Context() context.Context
Context mocks base method.
func (*MockCliToHub_ExecuteClient) EXPECT ¶
func (m *MockCliToHub_ExecuteClient) EXPECT() *MockCliToHub_ExecuteClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_ExecuteClient) Header ¶
func (m *MockCliToHub_ExecuteClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockCliToHub_ExecuteClient) Recv ¶
func (m *MockCliToHub_ExecuteClient) Recv() (*idl.Message, error)
Recv mocks base method.
func (*MockCliToHub_ExecuteClient) RecvMsg ¶
func (m_2 *MockCliToHub_ExecuteClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_ExecuteClient) SendMsg ¶
func (m_2 *MockCliToHub_ExecuteClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_ExecuteClient) Trailer ¶
func (m *MockCliToHub_ExecuteClient) Trailer() metadata.MD
Trailer mocks base method.
type MockCliToHub_ExecuteClientMockRecorder ¶
type MockCliToHub_ExecuteClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_ExecuteClientMockRecorder is the mock recorder for MockCliToHub_ExecuteClient.
func (*MockCliToHub_ExecuteClientMockRecorder) CloseSend ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockCliToHub_ExecuteClientMockRecorder) Context ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_ExecuteClientMockRecorder) Header ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockCliToHub_ExecuteClientMockRecorder) Recv ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockCliToHub_ExecuteClientMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_ExecuteClientMockRecorder) SendMsg ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_ExecuteClientMockRecorder) Trailer ¶
func (mr *MockCliToHub_ExecuteClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockCliToHub_ExecuteServer ¶
type MockCliToHub_ExecuteServer struct {
// contains filtered or unexported fields
}
MockCliToHub_ExecuteServer is a mock of CliToHub_ExecuteServer interface.
func NewMockCliToHub_ExecuteServer ¶
func NewMockCliToHub_ExecuteServer(ctrl *gomock.Controller) *MockCliToHub_ExecuteServer
NewMockCliToHub_ExecuteServer creates a new mock instance.
func (*MockCliToHub_ExecuteServer) Context ¶
func (m *MockCliToHub_ExecuteServer) Context() context.Context
Context mocks base method.
func (*MockCliToHub_ExecuteServer) EXPECT ¶
func (m *MockCliToHub_ExecuteServer) EXPECT() *MockCliToHub_ExecuteServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_ExecuteServer) RecvMsg ¶
func (m_2 *MockCliToHub_ExecuteServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_ExecuteServer) Send ¶
func (m *MockCliToHub_ExecuteServer) Send(arg0 *idl.Message) error
Send mocks base method.
func (*MockCliToHub_ExecuteServer) SendHeader ¶
func (m *MockCliToHub_ExecuteServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockCliToHub_ExecuteServer) SendMsg ¶
func (m_2 *MockCliToHub_ExecuteServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_ExecuteServer) SetHeader ¶
func (m *MockCliToHub_ExecuteServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockCliToHub_ExecuteServer) SetTrailer ¶
func (m *MockCliToHub_ExecuteServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockCliToHub_ExecuteServerMockRecorder ¶
type MockCliToHub_ExecuteServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_ExecuteServerMockRecorder is the mock recorder for MockCliToHub_ExecuteServer.
func (*MockCliToHub_ExecuteServerMockRecorder) Context ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_ExecuteServerMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_ExecuteServerMockRecorder) Send ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockCliToHub_ExecuteServerMockRecorder) SendHeader ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockCliToHub_ExecuteServerMockRecorder) SendMsg ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_ExecuteServerMockRecorder) SetHeader ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockCliToHub_ExecuteServerMockRecorder) SetTrailer ¶
func (mr *MockCliToHub_ExecuteServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockCliToHub_FinalizeClient ¶
type MockCliToHub_FinalizeClient struct {
// contains filtered or unexported fields
}
MockCliToHub_FinalizeClient is a mock of CliToHub_FinalizeClient interface.
func NewMockCliToHub_FinalizeClient ¶
func NewMockCliToHub_FinalizeClient(ctrl *gomock.Controller) *MockCliToHub_FinalizeClient
NewMockCliToHub_FinalizeClient creates a new mock instance.
func (*MockCliToHub_FinalizeClient) CloseSend ¶
func (m *MockCliToHub_FinalizeClient) CloseSend() error
CloseSend mocks base method.
func (*MockCliToHub_FinalizeClient) Context ¶
func (m *MockCliToHub_FinalizeClient) Context() context.Context
Context mocks base method.
func (*MockCliToHub_FinalizeClient) EXPECT ¶
func (m *MockCliToHub_FinalizeClient) EXPECT() *MockCliToHub_FinalizeClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_FinalizeClient) Header ¶
func (m *MockCliToHub_FinalizeClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockCliToHub_FinalizeClient) Recv ¶
func (m *MockCliToHub_FinalizeClient) Recv() (*idl.Message, error)
Recv mocks base method.
func (*MockCliToHub_FinalizeClient) RecvMsg ¶
func (m_2 *MockCliToHub_FinalizeClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_FinalizeClient) SendMsg ¶
func (m_2 *MockCliToHub_FinalizeClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_FinalizeClient) Trailer ¶
func (m *MockCliToHub_FinalizeClient) Trailer() metadata.MD
Trailer mocks base method.
type MockCliToHub_FinalizeClientMockRecorder ¶
type MockCliToHub_FinalizeClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_FinalizeClientMockRecorder is the mock recorder for MockCliToHub_FinalizeClient.
func (*MockCliToHub_FinalizeClientMockRecorder) CloseSend ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockCliToHub_FinalizeClientMockRecorder) Context ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_FinalizeClientMockRecorder) Header ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockCliToHub_FinalizeClientMockRecorder) Recv ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockCliToHub_FinalizeClientMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_FinalizeClientMockRecorder) SendMsg ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_FinalizeClientMockRecorder) Trailer ¶
func (mr *MockCliToHub_FinalizeClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockCliToHub_FinalizeServer ¶
type MockCliToHub_FinalizeServer struct {
// contains filtered or unexported fields
}
MockCliToHub_FinalizeServer is a mock of CliToHub_FinalizeServer interface.
func NewMockCliToHub_FinalizeServer ¶
func NewMockCliToHub_FinalizeServer(ctrl *gomock.Controller) *MockCliToHub_FinalizeServer
NewMockCliToHub_FinalizeServer creates a new mock instance.
func (*MockCliToHub_FinalizeServer) Context ¶
func (m *MockCliToHub_FinalizeServer) Context() context.Context
Context mocks base method.
func (*MockCliToHub_FinalizeServer) EXPECT ¶
func (m *MockCliToHub_FinalizeServer) EXPECT() *MockCliToHub_FinalizeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_FinalizeServer) RecvMsg ¶
func (m_2 *MockCliToHub_FinalizeServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_FinalizeServer) Send ¶
func (m *MockCliToHub_FinalizeServer) Send(arg0 *idl.Message) error
Send mocks base method.
func (*MockCliToHub_FinalizeServer) SendHeader ¶
func (m *MockCliToHub_FinalizeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockCliToHub_FinalizeServer) SendMsg ¶
func (m_2 *MockCliToHub_FinalizeServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_FinalizeServer) SetHeader ¶
func (m *MockCliToHub_FinalizeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockCliToHub_FinalizeServer) SetTrailer ¶
func (m *MockCliToHub_FinalizeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockCliToHub_FinalizeServerMockRecorder ¶
type MockCliToHub_FinalizeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_FinalizeServerMockRecorder is the mock recorder for MockCliToHub_FinalizeServer.
func (*MockCliToHub_FinalizeServerMockRecorder) Context ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_FinalizeServerMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_FinalizeServerMockRecorder) Send ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockCliToHub_FinalizeServerMockRecorder) SendHeader ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockCliToHub_FinalizeServerMockRecorder) SendMsg ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_FinalizeServerMockRecorder) SetHeader ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockCliToHub_FinalizeServerMockRecorder) SetTrailer ¶
func (mr *MockCliToHub_FinalizeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockCliToHub_InitializeClient ¶
type MockCliToHub_InitializeClient struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeClient is a mock of CliToHub_InitializeClient interface.
func NewMockCliToHub_InitializeClient ¶
func NewMockCliToHub_InitializeClient(ctrl *gomock.Controller) *MockCliToHub_InitializeClient
NewMockCliToHub_InitializeClient creates a new mock instance.
func (*MockCliToHub_InitializeClient) CloseSend ¶
func (m *MockCliToHub_InitializeClient) CloseSend() error
CloseSend mocks base method.
func (*MockCliToHub_InitializeClient) Context ¶
func (m *MockCliToHub_InitializeClient) Context() context.Context
Context mocks base method.
func (*MockCliToHub_InitializeClient) EXPECT ¶
func (m *MockCliToHub_InitializeClient) EXPECT() *MockCliToHub_InitializeClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_InitializeClient) Header ¶
func (m *MockCliToHub_InitializeClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockCliToHub_InitializeClient) Recv ¶
func (m *MockCliToHub_InitializeClient) Recv() (*idl.Message, error)
Recv mocks base method.
func (*MockCliToHub_InitializeClient) RecvMsg ¶
func (m_2 *MockCliToHub_InitializeClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_InitializeClient) SendMsg ¶
func (m_2 *MockCliToHub_InitializeClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_InitializeClient) Trailer ¶
func (m *MockCliToHub_InitializeClient) Trailer() metadata.MD
Trailer mocks base method.
type MockCliToHub_InitializeClientMockRecorder ¶
type MockCliToHub_InitializeClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeClientMockRecorder is the mock recorder for MockCliToHub_InitializeClient.
func (*MockCliToHub_InitializeClientMockRecorder) CloseSend ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockCliToHub_InitializeClientMockRecorder) Context ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_InitializeClientMockRecorder) Header ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockCliToHub_InitializeClientMockRecorder) Recv ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockCliToHub_InitializeClientMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_InitializeClientMockRecorder) SendMsg ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_InitializeClientMockRecorder) Trailer ¶
func (mr *MockCliToHub_InitializeClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockCliToHub_InitializeCreateClusterClient ¶
type MockCliToHub_InitializeCreateClusterClient struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeCreateClusterClient is a mock of CliToHub_InitializeCreateClusterClient interface.
func NewMockCliToHub_InitializeCreateClusterClient ¶
func NewMockCliToHub_InitializeCreateClusterClient(ctrl *gomock.Controller) *MockCliToHub_InitializeCreateClusterClient
NewMockCliToHub_InitializeCreateClusterClient creates a new mock instance.
func (*MockCliToHub_InitializeCreateClusterClient) CloseSend ¶
func (m *MockCliToHub_InitializeCreateClusterClient) CloseSend() error
CloseSend mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) Context ¶
func (m *MockCliToHub_InitializeCreateClusterClient) Context() context.Context
Context mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) EXPECT ¶
func (m *MockCliToHub_InitializeCreateClusterClient) EXPECT() *MockCliToHub_InitializeCreateClusterClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_InitializeCreateClusterClient) Header ¶
func (m *MockCliToHub_InitializeCreateClusterClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) Recv ¶
func (m *MockCliToHub_InitializeCreateClusterClient) Recv() (*idl.Message, error)
Recv mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) RecvMsg ¶
func (m_2 *MockCliToHub_InitializeCreateClusterClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) SendMsg ¶
func (m_2 *MockCliToHub_InitializeCreateClusterClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_InitializeCreateClusterClient) Trailer ¶
func (m *MockCliToHub_InitializeCreateClusterClient) Trailer() metadata.MD
Trailer mocks base method.
type MockCliToHub_InitializeCreateClusterClientMockRecorder ¶
type MockCliToHub_InitializeCreateClusterClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeCreateClusterClientMockRecorder is the mock recorder for MockCliToHub_InitializeCreateClusterClient.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) CloseSend ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) Context ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) Header ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) Recv ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) SendMsg ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_InitializeCreateClusterClientMockRecorder) Trailer ¶
func (mr *MockCliToHub_InitializeCreateClusterClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockCliToHub_InitializeCreateClusterServer ¶
type MockCliToHub_InitializeCreateClusterServer struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeCreateClusterServer is a mock of CliToHub_InitializeCreateClusterServer interface.
func NewMockCliToHub_InitializeCreateClusterServer ¶
func NewMockCliToHub_InitializeCreateClusterServer(ctrl *gomock.Controller) *MockCliToHub_InitializeCreateClusterServer
NewMockCliToHub_InitializeCreateClusterServer creates a new mock instance.
func (*MockCliToHub_InitializeCreateClusterServer) Context ¶
func (m *MockCliToHub_InitializeCreateClusterServer) Context() context.Context
Context mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) EXPECT ¶
func (m *MockCliToHub_InitializeCreateClusterServer) EXPECT() *MockCliToHub_InitializeCreateClusterServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_InitializeCreateClusterServer) RecvMsg ¶
func (m_2 *MockCliToHub_InitializeCreateClusterServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) Send ¶
func (m *MockCliToHub_InitializeCreateClusterServer) Send(arg0 *idl.Message) error
Send mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) SendHeader ¶
func (m *MockCliToHub_InitializeCreateClusterServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) SendMsg ¶
func (m_2 *MockCliToHub_InitializeCreateClusterServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) SetHeader ¶
func (m *MockCliToHub_InitializeCreateClusterServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockCliToHub_InitializeCreateClusterServer) SetTrailer ¶
func (m *MockCliToHub_InitializeCreateClusterServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockCliToHub_InitializeCreateClusterServerMockRecorder ¶
type MockCliToHub_InitializeCreateClusterServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeCreateClusterServerMockRecorder is the mock recorder for MockCliToHub_InitializeCreateClusterServer.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) Context ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) Send ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) SendHeader ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) SendMsg ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) SetHeader ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockCliToHub_InitializeCreateClusterServerMockRecorder) SetTrailer ¶
func (mr *MockCliToHub_InitializeCreateClusterServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockCliToHub_InitializeServer ¶
type MockCliToHub_InitializeServer struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeServer is a mock of CliToHub_InitializeServer interface.
func NewMockCliToHub_InitializeServer ¶
func NewMockCliToHub_InitializeServer(ctrl *gomock.Controller) *MockCliToHub_InitializeServer
NewMockCliToHub_InitializeServer creates a new mock instance.
func (*MockCliToHub_InitializeServer) Context ¶
func (m *MockCliToHub_InitializeServer) Context() context.Context
Context mocks base method.
func (*MockCliToHub_InitializeServer) EXPECT ¶
func (m *MockCliToHub_InitializeServer) EXPECT() *MockCliToHub_InitializeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_InitializeServer) RecvMsg ¶
func (m_2 *MockCliToHub_InitializeServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_InitializeServer) Send ¶
func (m *MockCliToHub_InitializeServer) Send(arg0 *idl.Message) error
Send mocks base method.
func (*MockCliToHub_InitializeServer) SendHeader ¶
func (m *MockCliToHub_InitializeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockCliToHub_InitializeServer) SendMsg ¶
func (m_2 *MockCliToHub_InitializeServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_InitializeServer) SetHeader ¶
func (m *MockCliToHub_InitializeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockCliToHub_InitializeServer) SetTrailer ¶
func (m *MockCliToHub_InitializeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockCliToHub_InitializeServerMockRecorder ¶
type MockCliToHub_InitializeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_InitializeServerMockRecorder is the mock recorder for MockCliToHub_InitializeServer.
func (*MockCliToHub_InitializeServerMockRecorder) Context ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_InitializeServerMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_InitializeServerMockRecorder) Send ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockCliToHub_InitializeServerMockRecorder) SendHeader ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockCliToHub_InitializeServerMockRecorder) SendMsg ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_InitializeServerMockRecorder) SetHeader ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockCliToHub_InitializeServerMockRecorder) SetTrailer ¶
func (mr *MockCliToHub_InitializeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockCliToHub_RevertClient ¶
type MockCliToHub_RevertClient struct {
// contains filtered or unexported fields
}
MockCliToHub_RevertClient is a mock of CliToHub_RevertClient interface.
func NewMockCliToHub_RevertClient ¶
func NewMockCliToHub_RevertClient(ctrl *gomock.Controller) *MockCliToHub_RevertClient
NewMockCliToHub_RevertClient creates a new mock instance.
func (*MockCliToHub_RevertClient) CloseSend ¶
func (m *MockCliToHub_RevertClient) CloseSend() error
CloseSend mocks base method.
func (*MockCliToHub_RevertClient) Context ¶
func (m *MockCliToHub_RevertClient) Context() context.Context
Context mocks base method.
func (*MockCliToHub_RevertClient) EXPECT ¶
func (m *MockCliToHub_RevertClient) EXPECT() *MockCliToHub_RevertClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_RevertClient) Header ¶
func (m *MockCliToHub_RevertClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockCliToHub_RevertClient) Recv ¶
func (m *MockCliToHub_RevertClient) Recv() (*idl.Message, error)
Recv mocks base method.
func (*MockCliToHub_RevertClient) RecvMsg ¶
func (m_2 *MockCliToHub_RevertClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_RevertClient) SendMsg ¶
func (m_2 *MockCliToHub_RevertClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_RevertClient) Trailer ¶
func (m *MockCliToHub_RevertClient) Trailer() metadata.MD
Trailer mocks base method.
type MockCliToHub_RevertClientMockRecorder ¶
type MockCliToHub_RevertClientMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_RevertClientMockRecorder is the mock recorder for MockCliToHub_RevertClient.
func (*MockCliToHub_RevertClientMockRecorder) CloseSend ¶
func (mr *MockCliToHub_RevertClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockCliToHub_RevertClientMockRecorder) Context ¶
func (mr *MockCliToHub_RevertClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_RevertClientMockRecorder) Header ¶
func (mr *MockCliToHub_RevertClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockCliToHub_RevertClientMockRecorder) Recv ¶
func (mr *MockCliToHub_RevertClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockCliToHub_RevertClientMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_RevertClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_RevertClientMockRecorder) SendMsg ¶
func (mr *MockCliToHub_RevertClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_RevertClientMockRecorder) Trailer ¶
func (mr *MockCliToHub_RevertClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockCliToHub_RevertServer ¶
type MockCliToHub_RevertServer struct {
// contains filtered or unexported fields
}
MockCliToHub_RevertServer is a mock of CliToHub_RevertServer interface.
func NewMockCliToHub_RevertServer ¶
func NewMockCliToHub_RevertServer(ctrl *gomock.Controller) *MockCliToHub_RevertServer
NewMockCliToHub_RevertServer creates a new mock instance.
func (*MockCliToHub_RevertServer) Context ¶
func (m *MockCliToHub_RevertServer) Context() context.Context
Context mocks base method.
func (*MockCliToHub_RevertServer) EXPECT ¶
func (m *MockCliToHub_RevertServer) EXPECT() *MockCliToHub_RevertServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCliToHub_RevertServer) RecvMsg ¶
func (m_2 *MockCliToHub_RevertServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockCliToHub_RevertServer) Send ¶
func (m *MockCliToHub_RevertServer) Send(arg0 *idl.Message) error
Send mocks base method.
func (*MockCliToHub_RevertServer) SendHeader ¶
func (m *MockCliToHub_RevertServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockCliToHub_RevertServer) SendMsg ¶
func (m_2 *MockCliToHub_RevertServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockCliToHub_RevertServer) SetHeader ¶
func (m *MockCliToHub_RevertServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockCliToHub_RevertServer) SetTrailer ¶
func (m *MockCliToHub_RevertServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockCliToHub_RevertServerMockRecorder ¶
type MockCliToHub_RevertServerMockRecorder struct {
// contains filtered or unexported fields
}
MockCliToHub_RevertServerMockRecorder is the mock recorder for MockCliToHub_RevertServer.
func (*MockCliToHub_RevertServerMockRecorder) Context ¶
func (mr *MockCliToHub_RevertServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockCliToHub_RevertServerMockRecorder) RecvMsg ¶
func (mr *MockCliToHub_RevertServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockCliToHub_RevertServerMockRecorder) Send ¶
func (mr *MockCliToHub_RevertServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockCliToHub_RevertServerMockRecorder) SendHeader ¶
func (mr *MockCliToHub_RevertServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockCliToHub_RevertServerMockRecorder) SendMsg ¶
func (mr *MockCliToHub_RevertServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockCliToHub_RevertServerMockRecorder) SetHeader ¶
func (mr *MockCliToHub_RevertServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockCliToHub_RevertServerMockRecorder) SetTrailer ¶
func (mr *MockCliToHub_RevertServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockUnsafeAgentServer ¶
type MockUnsafeAgentServer struct {
// contains filtered or unexported fields
}
MockUnsafeAgentServer is a mock of UnsafeAgentServer interface.
func NewMockUnsafeAgentServer ¶
func NewMockUnsafeAgentServer(ctrl *gomock.Controller) *MockUnsafeAgentServer
NewMockUnsafeAgentServer creates a new mock instance.
func (*MockUnsafeAgentServer) EXPECT ¶
func (m *MockUnsafeAgentServer) EXPECT() *MockUnsafeAgentServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeAgentServerMockRecorder ¶
type MockUnsafeAgentServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeAgentServerMockRecorder is the mock recorder for MockUnsafeAgentServer.
type MockUnsafeCliToHubServer ¶
type MockUnsafeCliToHubServer struct {
// contains filtered or unexported fields
}
MockUnsafeCliToHubServer is a mock of UnsafeCliToHubServer interface.
func NewMockUnsafeCliToHubServer ¶
func NewMockUnsafeCliToHubServer(ctrl *gomock.Controller) *MockUnsafeCliToHubServer
NewMockUnsafeCliToHubServer creates a new mock instance.
func (*MockUnsafeCliToHubServer) EXPECT ¶
func (m *MockUnsafeCliToHubServer) EXPECT() *MockUnsafeCliToHubServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeCliToHubServerMockRecorder ¶
type MockUnsafeCliToHubServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeCliToHubServerMockRecorder is the mock recorder for MockUnsafeCliToHubServer.