mock

package
v0.20.0 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Index

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 any, arg2 ...any) *gomock.Call

AddPeer indicates an expected call of AddPeer.

func (*MockManagementClientMockRecorder) GetClusterInfo 

func (mr *MockManagementClientMockRecorder) GetClusterInfo(arg0, arg1 any, arg2 ...any) *gomock.Call

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockManagementClientMockRecorder) RemovePeer 

func (mr *MockManagementClientMockRecorder) RemovePeer(arg0, arg1 any, arg2 ...any) *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 any) *gomock.Call

AddPeer indicates an expected call of AddPeer.

func (*MockManagementServerMockRecorder) GetClusterInfo 

func (mr *MockManagementServerMockRecorder) GetClusterInfo(arg0, arg1 any) *gomock.Call

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockManagementServerMockRecorder) RemovePeer 

func (mr *MockManagementServerMockRecorder) RemovePeer(arg0, arg1 any) *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 any, arg2 ...any) *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterLogStream 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterLogStream(arg0, arg1 any, arg2 ...any) *gomock.Call

RegisterLogStream indicates an expected call of RegisterLogStream.

func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterStorageNode 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterStorageNode(arg0, arg1 any, arg2 ...any) *gomock.Call

RegisterStorageNode indicates an expected call of RegisterStorageNode.

func (*MockMetadataRepositoryServiceClientMockRecorder) RegisterTopic 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) RegisterTopic(arg0, arg1 any, arg2 ...any) *gomock.Call

RegisterTopic indicates an expected call of RegisterTopic.

func (*MockMetadataRepositoryServiceClientMockRecorder) Seal 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) Seal(arg0, arg1 any, arg2 ...any) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterLogStream 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterLogStream(arg0, arg1 any, arg2 ...any) *gomock.Call

UnregisterLogStream indicates an expected call of UnregisterLogStream.

func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterStorageNode 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterStorageNode(arg0, arg1 any, arg2 ...any) *gomock.Call

UnregisterStorageNode indicates an expected call of UnregisterStorageNode.

func (*MockMetadataRepositoryServiceClientMockRecorder) UnregisterTopic 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) UnregisterTopic(arg0, arg1 any, arg2 ...any) *gomock.Call

UnregisterTopic indicates an expected call of UnregisterTopic.

func (*MockMetadataRepositoryServiceClientMockRecorder) Unseal 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) Unseal(arg0, arg1 any, arg2 ...any) *gomock.Call

Unseal indicates an expected call of Unseal.

func (*MockMetadataRepositoryServiceClientMockRecorder) UpdateLogStream 

func (mr *MockMetadataRepositoryServiceClientMockRecorder) UpdateLogStream(arg0, arg1 any, arg2 ...any) *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 any) *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterLogStream 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterLogStream(arg0, arg1 any) *gomock.Call

RegisterLogStream indicates an expected call of RegisterLogStream.

func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterStorageNode 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterStorageNode(arg0, arg1 any) *gomock.Call

RegisterStorageNode indicates an expected call of RegisterStorageNode.

func (*MockMetadataRepositoryServiceServerMockRecorder) RegisterTopic 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) RegisterTopic(arg0, arg1 any) *gomock.Call

RegisterTopic indicates an expected call of RegisterTopic.

func (*MockMetadataRepositoryServiceServerMockRecorder) Seal 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) Seal(arg0, arg1 any) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterLogStream 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterLogStream(arg0, arg1 any) *gomock.Call

UnregisterLogStream indicates an expected call of UnregisterLogStream.

func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterStorageNode 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterStorageNode(arg0, arg1 any) *gomock.Call

UnregisterStorageNode indicates an expected call of UnregisterStorageNode.

func (*MockMetadataRepositoryServiceServerMockRecorder) UnregisterTopic 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) UnregisterTopic(arg0, arg1 any) *gomock.Call

UnregisterTopic indicates an expected call of UnregisterTopic.

func (*MockMetadataRepositoryServiceServerMockRecorder) Unseal 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) Unseal(arg0, arg1 any) *gomock.Call

Unseal indicates an expected call of Unseal.

func (*MockMetadataRepositoryServiceServerMockRecorder) UpdateLogStream 

func (mr *MockMetadataRepositoryServiceServerMockRecorder) UpdateLogStream(arg0, arg1 any) *gomock.Call

UpdateLogStream indicates an expected call of UpdateLogStream.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.