Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockManagementClient
- func (m *MockManagementClient) AddPeer(arg0 context.Context, arg1 *mrpb.AddPeerRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockManagementClient) EXPECT() *MockManagementClientMockRecorder
- func (m *MockManagementClient) GetClusterInfo(arg0 context.Context, arg1 *mrpb.GetClusterInfoRequest, ...) (*mrpb.GetClusterInfoResponse, error)
- func (m *MockManagementClient) RemovePeer(arg0 context.Context, arg1 *mrpb.RemovePeerRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- type MockManagementClientMockRecorder
- func (mr *MockManagementClientMockRecorder) AddPeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockManagementClientMockRecorder) GetClusterInfo(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockManagementClientMockRecorder) RemovePeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockManagementServer
- func (m *MockManagementServer) AddPeer(arg0 context.Context, arg1 *mrpb.AddPeerRequest) (*types.Empty, error)
- func (m *MockManagementServer) EXPECT() *MockManagementServerMockRecorder
- func (m *MockManagementServer) GetClusterInfo(arg0 context.Context, arg1 *mrpb.GetClusterInfoRequest) (*mrpb.GetClusterInfoResponse, error)
- func (m *MockManagementServer) RemovePeer(arg0 context.Context, arg1 *mrpb.RemovePeerRequest) (*types.Empty, error)
- type MockManagementServerMockRecorder
- type MockMetadataRepositoryServiceClient
- func (m *MockMetadataRepositoryServiceClient) EXPECT() *MockMetadataRepositoryServiceClientMockRecorder
- func (m *MockMetadataRepositoryServiceClient) GetMetadata(arg0 context.Context, arg1 *mrpb.GetMetadataRequest, arg2 ...grpc.CallOption) (*mrpb.GetMetadataResponse, error)
- func (m *MockMetadataRepositoryServiceClient) RegisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) RegisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) RegisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) Seal(arg0 context.Context, arg1 *mrpb.SealRequest, arg2 ...grpc.CallOption) (*mrpb.SealResponse, error)
- func (m *MockMetadataRepositoryServiceClient) UnregisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) UnregisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) UnregisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceClient) Unseal(arg0 context.Context, arg1 *mrpb.UnsealRequest, arg2 ...grpc.CallOption) (*mrpb.UnsealResponse, error)
- func (m *MockMetadataRepositoryServiceClient) UpdateLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
- type MockMetadataRepositoryServiceClientMockRecorder
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) GetMetadata(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) Seal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) Unseal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceClientMockRecorder) UpdateLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockMetadataRepositoryServiceServer
- func (m *MockMetadataRepositoryServiceServer) EXPECT() *MockMetadataRepositoryServiceServerMockRecorder
- func (m *MockMetadataRepositoryServiceServer) GetMetadata(arg0 context.Context, arg1 *mrpb.GetMetadataRequest) (*mrpb.GetMetadataResponse, error)
- func (m *MockMetadataRepositoryServiceServer) RegisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) RegisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) RegisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) Seal(arg0 context.Context, arg1 *mrpb.SealRequest) (*mrpb.SealResponse, error)
- func (m *MockMetadataRepositoryServiceServer) UnregisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) UnregisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) UnregisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest) (*types.Empty, error)
- func (m *MockMetadataRepositoryServiceServer) Unseal(arg0 context.Context, arg1 *mrpb.UnsealRequest) (*mrpb.UnsealResponse, error)
- func (m *MockMetadataRepositoryServiceServer) UpdateLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
- type MockMetadataRepositoryServiceServerMockRecorder
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) GetMetadata(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterLogStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterStorageNode(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterTopic(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) Seal(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterLogStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterTopic(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) Unseal(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMetadataRepositoryServiceServerMockRecorder) UpdateLogStream(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockManagementClient ¶
type MockManagementClient struct {
// contains filtered or unexported fields
}
MockManagementClient is a mock of ManagementClient interface.
func NewMockManagementClient ¶
func NewMockManagementClient(ctrl *gomock.Controller) *MockManagementClient
NewMockManagementClient creates a new mock instance.
func (*MockManagementClient) AddPeer ¶
func (m *MockManagementClient) AddPeer(arg0 context.Context, arg1 *mrpb.AddPeerRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
AddPeer mocks base method.
func (*MockManagementClient) EXPECT ¶
func (m *MockManagementClient) EXPECT() *MockManagementClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManagementClient) GetClusterInfo ¶
func (m *MockManagementClient) GetClusterInfo(arg0 context.Context, arg1 *mrpb.GetClusterInfoRequest, arg2 ...grpc.CallOption) (*mrpb.GetClusterInfoResponse, error)
GetClusterInfo mocks base method.
func (*MockManagementClient) RemovePeer ¶
func (m *MockManagementClient) RemovePeer(arg0 context.Context, arg1 *mrpb.RemovePeerRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
RemovePeer mocks base method.
type MockManagementClientMockRecorder ¶
type MockManagementClientMockRecorder struct {
// contains filtered or unexported fields
}
MockManagementClientMockRecorder is the mock recorder for MockManagementClient.
func (*MockManagementClientMockRecorder) AddPeer ¶
func (mr *MockManagementClientMockRecorder) AddPeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
AddPeer indicates an expected call of AddPeer.
func (*MockManagementClientMockRecorder) GetClusterInfo ¶
func (mr *MockManagementClientMockRecorder) GetClusterInfo(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetClusterInfo indicates an expected call of GetClusterInfo.
func (*MockManagementClientMockRecorder) RemovePeer ¶
func (mr *MockManagementClientMockRecorder) RemovePeer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RemovePeer indicates an expected call of RemovePeer.
type MockManagementServer ¶
type MockManagementServer struct {
// contains filtered or unexported fields
}
MockManagementServer is a mock of ManagementServer interface.
func NewMockManagementServer ¶
func NewMockManagementServer(ctrl *gomock.Controller) *MockManagementServer
NewMockManagementServer creates a new mock instance.
func (*MockManagementServer) AddPeer ¶
func (m *MockManagementServer) AddPeer(arg0 context.Context, arg1 *mrpb.AddPeerRequest) (*types.Empty, error)
AddPeer mocks base method.
func (*MockManagementServer) EXPECT ¶
func (m *MockManagementServer) EXPECT() *MockManagementServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManagementServer) GetClusterInfo ¶
func (m *MockManagementServer) GetClusterInfo(arg0 context.Context, arg1 *mrpb.GetClusterInfoRequest) (*mrpb.GetClusterInfoResponse, error)
GetClusterInfo mocks base method.
func (*MockManagementServer) RemovePeer ¶
func (m *MockManagementServer) RemovePeer(arg0 context.Context, arg1 *mrpb.RemovePeerRequest) (*types.Empty, error)
RemovePeer mocks base method.
type MockManagementServerMockRecorder ¶
type MockManagementServerMockRecorder struct {
// contains filtered or unexported fields
}
MockManagementServerMockRecorder is the mock recorder for MockManagementServer.
func (*MockManagementServerMockRecorder) AddPeer ¶
func (mr *MockManagementServerMockRecorder) AddPeer(arg0, arg1 interface{}) *gomock.Call
AddPeer indicates an expected call of AddPeer.
func (*MockManagementServerMockRecorder) GetClusterInfo ¶
func (mr *MockManagementServerMockRecorder) GetClusterInfo(arg0, arg1 interface{}) *gomock.Call
GetClusterInfo indicates an expected call of GetClusterInfo.
func (*MockManagementServerMockRecorder) RemovePeer ¶
func (mr *MockManagementServerMockRecorder) RemovePeer(arg0, arg1 interface{}) *gomock.Call
RemovePeer indicates an expected call of RemovePeer.
type MockMetadataRepositoryServiceClient ¶
type MockMetadataRepositoryServiceClient struct {
// contains filtered or unexported fields
}
MockMetadataRepositoryServiceClient is a mock of MetadataRepositoryServiceClient interface.
func NewMockMetadataRepositoryServiceClient ¶
func NewMockMetadataRepositoryServiceClient(ctrl *gomock.Controller) *MockMetadataRepositoryServiceClient
NewMockMetadataRepositoryServiceClient creates a new mock instance.
func (*MockMetadataRepositoryServiceClient) EXPECT ¶
func (m *MockMetadataRepositoryServiceClient) EXPECT() *MockMetadataRepositoryServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMetadataRepositoryServiceClient) GetMetadata ¶
func (m *MockMetadataRepositoryServiceClient) GetMetadata(arg0 context.Context, arg1 *mrpb.GetMetadataRequest, arg2 ...grpc.CallOption) (*mrpb.GetMetadataResponse, error)
GetMetadata mocks base method.
func (*MockMetadataRepositoryServiceClient) RegisterLogStream ¶
func (m *MockMetadataRepositoryServiceClient) RegisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
RegisterLogStream mocks base method.
func (*MockMetadataRepositoryServiceClient) RegisterStorageNode ¶
func (m *MockMetadataRepositoryServiceClient) RegisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
RegisterStorageNode mocks base method.
func (*MockMetadataRepositoryServiceClient) RegisterTopic ¶
func (m *MockMetadataRepositoryServiceClient) RegisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
RegisterTopic mocks base method.
func (*MockMetadataRepositoryServiceClient) Seal ¶
func (m *MockMetadataRepositoryServiceClient) Seal(arg0 context.Context, arg1 *mrpb.SealRequest, arg2 ...grpc.CallOption) (*mrpb.SealResponse, error)
Seal mocks base method.
func (*MockMetadataRepositoryServiceClient) UnregisterLogStream ¶
func (m *MockMetadataRepositoryServiceClient) UnregisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
UnregisterLogStream mocks base method.
func (*MockMetadataRepositoryServiceClient) UnregisterStorageNode ¶
func (m *MockMetadataRepositoryServiceClient) UnregisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
UnregisterStorageNode mocks base method.
func (*MockMetadataRepositoryServiceClient) UnregisterTopic ¶
func (m *MockMetadataRepositoryServiceClient) UnregisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
UnregisterTopic mocks base method.
func (*MockMetadataRepositoryServiceClient) Unseal ¶
func (m *MockMetadataRepositoryServiceClient) Unseal(arg0 context.Context, arg1 *mrpb.UnsealRequest, arg2 ...grpc.CallOption) (*mrpb.UnsealResponse, error)
Unseal mocks base method.
func (*MockMetadataRepositoryServiceClient) UpdateLogStream ¶
func (m *MockMetadataRepositoryServiceClient) UpdateLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)
UpdateLogStream mocks base method.
type MockMetadataRepositoryServiceClientMockRecorder ¶
type MockMetadataRepositoryServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockMetadataRepositoryServiceClientMockRecorder is the mock recorder for MockMetadataRepositoryServiceClient.
func (*MockMetadataRepositoryServiceClientMockRecorder) GetMetadata ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) GetMetadata(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetMetadata indicates an expected call of GetMetadata.
func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterLogStream ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterLogStream indicates an expected call of RegisterLogStream.
func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterStorageNode ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterStorageNode indicates an expected call of RegisterStorageNode.
func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterTopic ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterTopic indicates an expected call of RegisterTopic.
func (*MockMetadataRepositoryServiceClientMockRecorder) Seal ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) Seal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Seal indicates an expected call of Seal.
func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterLogStream ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UnregisterLogStream indicates an expected call of UnregisterLogStream.
func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterStorageNode ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UnregisterStorageNode indicates an expected call of UnregisterStorageNode.
func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterTopic ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterTopic(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UnregisterTopic indicates an expected call of UnregisterTopic.
func (*MockMetadataRepositoryServiceClientMockRecorder) Unseal ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) Unseal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Unseal indicates an expected call of Unseal.
func (*MockMetadataRepositoryServiceClientMockRecorder) UpdateLogStream ¶
func (mr *MockMetadataRepositoryServiceClientMockRecorder) UpdateLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateLogStream indicates an expected call of UpdateLogStream.
type MockMetadataRepositoryServiceServer ¶
type MockMetadataRepositoryServiceServer struct {
// contains filtered or unexported fields
}
MockMetadataRepositoryServiceServer is a mock of MetadataRepositoryServiceServer interface.
func NewMockMetadataRepositoryServiceServer ¶
func NewMockMetadataRepositoryServiceServer(ctrl *gomock.Controller) *MockMetadataRepositoryServiceServer
NewMockMetadataRepositoryServiceServer creates a new mock instance.
func (*MockMetadataRepositoryServiceServer) EXPECT ¶
func (m *MockMetadataRepositoryServiceServer) EXPECT() *MockMetadataRepositoryServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMetadataRepositoryServiceServer) GetMetadata ¶
func (m *MockMetadataRepositoryServiceServer) GetMetadata(arg0 context.Context, arg1 *mrpb.GetMetadataRequest) (*mrpb.GetMetadataResponse, error)
GetMetadata mocks base method.
func (*MockMetadataRepositoryServiceServer) RegisterLogStream ¶
func (m *MockMetadataRepositoryServiceServer) RegisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
RegisterLogStream mocks base method.
func (*MockMetadataRepositoryServiceServer) RegisterStorageNode ¶
func (m *MockMetadataRepositoryServiceServer) RegisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest) (*types.Empty, error)
RegisterStorageNode mocks base method.
func (*MockMetadataRepositoryServiceServer) RegisterTopic ¶
func (m *MockMetadataRepositoryServiceServer) RegisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest) (*types.Empty, error)
RegisterTopic mocks base method.
func (*MockMetadataRepositoryServiceServer) Seal ¶
func (m *MockMetadataRepositoryServiceServer) Seal(arg0 context.Context, arg1 *mrpb.SealRequest) (*mrpb.SealResponse, error)
Seal mocks base method.
func (*MockMetadataRepositoryServiceServer) UnregisterLogStream ¶
func (m *MockMetadataRepositoryServiceServer) UnregisterLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
UnregisterLogStream mocks base method.
func (*MockMetadataRepositoryServiceServer) UnregisterStorageNode ¶
func (m *MockMetadataRepositoryServiceServer) UnregisterStorageNode(arg0 context.Context, arg1 *mrpb.StorageNodeRequest) (*types.Empty, error)
UnregisterStorageNode mocks base method.
func (*MockMetadataRepositoryServiceServer) UnregisterTopic ¶
func (m *MockMetadataRepositoryServiceServer) UnregisterTopic(arg0 context.Context, arg1 *mrpb.TopicRequest) (*types.Empty, error)
UnregisterTopic mocks base method.
func (*MockMetadataRepositoryServiceServer) Unseal ¶
func (m *MockMetadataRepositoryServiceServer) Unseal(arg0 context.Context, arg1 *mrpb.UnsealRequest) (*mrpb.UnsealResponse, error)
Unseal mocks base method.
func (*MockMetadataRepositoryServiceServer) UpdateLogStream ¶
func (m *MockMetadataRepositoryServiceServer) UpdateLogStream(arg0 context.Context, arg1 *mrpb.LogStreamRequest) (*types.Empty, error)
UpdateLogStream mocks base method.
type MockMetadataRepositoryServiceServerMockRecorder ¶
type MockMetadataRepositoryServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockMetadataRepositoryServiceServerMockRecorder is the mock recorder for MockMetadataRepositoryServiceServer.
func (*MockMetadataRepositoryServiceServerMockRecorder) GetMetadata ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) GetMetadata(arg0, arg1 interface{}) *gomock.Call
GetMetadata indicates an expected call of GetMetadata.
func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterLogStream ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterLogStream(arg0, arg1 interface{}) *gomock.Call
RegisterLogStream indicates an expected call of RegisterLogStream.
func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterStorageNode ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterStorageNode(arg0, arg1 interface{}) *gomock.Call
RegisterStorageNode indicates an expected call of RegisterStorageNode.
func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterTopic ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterTopic(arg0, arg1 interface{}) *gomock.Call
RegisterTopic indicates an expected call of RegisterTopic.
func (*MockMetadataRepositoryServiceServerMockRecorder) Seal ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) Seal(arg0, arg1 interface{}) *gomock.Call
Seal indicates an expected call of Seal.
func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterLogStream ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterLogStream(arg0, arg1 interface{}) *gomock.Call
UnregisterLogStream indicates an expected call of UnregisterLogStream.
func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterStorageNode ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterStorageNode(arg0, arg1 interface{}) *gomock.Call
UnregisterStorageNode indicates an expected call of UnregisterStorageNode.
func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterTopic ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterTopic(arg0, arg1 interface{}) *gomock.Call
UnregisterTopic indicates an expected call of UnregisterTopic.
func (*MockMetadataRepositoryServiceServerMockRecorder) Unseal ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) Unseal(arg0, arg1 interface{}) *gomock.Call
Unseal indicates an expected call of Unseal.
func (*MockMetadataRepositoryServiceServerMockRecorder) UpdateLogStream ¶
func (mr *MockMetadataRepositoryServiceServerMockRecorder) UpdateLogStream(arg0, arg1 interface{}) *gomock.Call
UpdateLogStream indicates an expected call of UpdateLogStream.