mrc

package
v0.21.0 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package mrc is a generated GoMock package.

Package mrc is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetadataRepositoryClient 

type MetadataRepositoryClient interface {
	RegisterStorageNode(context.Context, *varlogpb.StorageNodeDescriptor) error
	UnregisterStorageNode(context.Context, types.StorageNodeID) error
	RegisterTopic(context.Context, types.TopicID) error
	UnregisterTopic(context.Context, types.TopicID) error
	RegisterLogStream(context.Context, *varlogpb.LogStreamDescriptor) error
	UnregisterLogStream(context.Context, types.LogStreamID) error
	UpdateLogStream(context.Context, *varlogpb.LogStreamDescriptor) error
	GetMetadata(context.Context) (*varlogpb.MetadataDescriptor, error)
	Seal(context.Context, types.LogStreamID) (types.GLSN, error)
	Unseal(context.Context, types.LogStreamID) error
	Close() error
}

func NewMetadataRepositoryClient 

func NewMetadataRepositoryClient(ctx context.Context, address string) (MetadataRepositoryClient, error)

FIXME (jun, pharrell): Use context or timeout, or remove health check.

func NewMetadataRepositoryClientFromRPCConn 

func NewMetadataRepositoryClientFromRPCConn(rpcConn *rpc.Conn) (MetadataRepositoryClient, error)

type MetadataRepositoryManagementClient 

type MetadataRepositoryManagementClient interface {
	AddPeer(ctx context.Context, clusterID types.ClusterID, nodeID types.NodeID, url string) error
	RemovePeer(ctx context.Context, clusterID types.ClusterID, nodeID types.NodeID) error
	GetClusterInfo(ctx context.Context, clusterID types.ClusterID) (*mrpb.GetClusterInfoResponse, error)
	Close() error
}

func NewMetadataRepositoryManagementClient 

func NewMetadataRepositoryManagementClient(ctx context.Context, address string) (MetadataRepositoryManagementClient, error)

func NewMetadataRepositoryManagementClientFromRPCConn 

func NewMetadataRepositoryManagementClientFromRPCConn(rpcConn *rpc.Conn) (MetadataRepositoryManagementClient, error)

type MockMetadataRepositoryClient 

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

MockMetadataRepositoryClient is a mock of MetadataRepositoryClient interface.

func NewMockMetadataRepositoryClient 

func NewMockMetadataRepositoryClient(ctrl *gomock.Controller) *MockMetadataRepositoryClient

NewMockMetadataRepositoryClient creates a new mock instance.

func (*MockMetadataRepositoryClient) Close 

func (m *MockMetadataRepositoryClient) Close() error

Close mocks base method.

func (*MockMetadataRepositoryClient) EXPECT 

func (m *MockMetadataRepositoryClient) EXPECT() *MockMetadataRepositoryClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataRepositoryClient) GetMetadata 

func (m *MockMetadataRepositoryClient) GetMetadata(arg0 context.Context) (*varlogpb.MetadataDescriptor, error)

GetMetadata mocks base method.

func (*MockMetadataRepositoryClient) RegisterLogStream 

func (m *MockMetadataRepositoryClient) RegisterLogStream(arg0 context.Context, arg1 *varlogpb.LogStreamDescriptor) error

RegisterLogStream mocks base method.

func (*MockMetadataRepositoryClient) RegisterStorageNode 

func (m *MockMetadataRepositoryClient) RegisterStorageNode(arg0 context.Context, arg1 *varlogpb.StorageNodeDescriptor) error

RegisterStorageNode mocks base method.

func (*MockMetadataRepositoryClient) RegisterTopic 

func (m *MockMetadataRepositoryClient) RegisterTopic(arg0 context.Context, arg1 types.TopicID) error

RegisterTopic mocks base method.

func (*MockMetadataRepositoryClient) Seal 

func (m *MockMetadataRepositoryClient) Seal(arg0 context.Context, arg1 types.LogStreamID) (types.GLSN, error)

Seal mocks base method.

func (*MockMetadataRepositoryClient) UnregisterLogStream 

func (m *MockMetadataRepositoryClient) UnregisterLogStream(arg0 context.Context, arg1 types.LogStreamID) error

UnregisterLogStream mocks base method.

func (*MockMetadataRepositoryClient) UnregisterStorageNode 

func (m *MockMetadataRepositoryClient) UnregisterStorageNode(arg0 context.Context, arg1 types.StorageNodeID) error

UnregisterStorageNode mocks base method.

func (*MockMetadataRepositoryClient) UnregisterTopic 

func (m *MockMetadataRepositoryClient) UnregisterTopic(arg0 context.Context, arg1 types.TopicID) error

UnregisterTopic mocks base method.

func (*MockMetadataRepositoryClient) Unseal 

func (m *MockMetadataRepositoryClient) Unseal(arg0 context.Context, arg1 types.LogStreamID) error

Unseal mocks base method.

func (*MockMetadataRepositoryClient) UpdateLogStream 

func (m *MockMetadataRepositoryClient) UpdateLogStream(arg0 context.Context, arg1 *varlogpb.LogStreamDescriptor) error

UpdateLogStream mocks base method.

type MockMetadataRepositoryClientMockRecorder 

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

MockMetadataRepositoryClientMockRecorder is the mock recorder for MockMetadataRepositoryClient.

func (*MockMetadataRepositoryClientMockRecorder) Close 

func (mr *MockMetadataRepositoryClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMetadataRepositoryClientMockRecorder) GetMetadata 

func (mr *MockMetadataRepositoryClientMockRecorder) GetMetadata(arg0 any) *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockMetadataRepositoryClientMockRecorder) RegisterLogStream 

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

RegisterLogStream indicates an expected call of RegisterLogStream.

func (*MockMetadataRepositoryClientMockRecorder) RegisterStorageNode 

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

RegisterStorageNode indicates an expected call of RegisterStorageNode.

func (*MockMetadataRepositoryClientMockRecorder) RegisterTopic 

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

RegisterTopic indicates an expected call of RegisterTopic.

func (*MockMetadataRepositoryClientMockRecorder) Seal 

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

Seal indicates an expected call of Seal.

func (*MockMetadataRepositoryClientMockRecorder) UnregisterLogStream 

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

UnregisterLogStream indicates an expected call of UnregisterLogStream.

func (*MockMetadataRepositoryClientMockRecorder) UnregisterStorageNode 

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

UnregisterStorageNode indicates an expected call of UnregisterStorageNode.

func (*MockMetadataRepositoryClientMockRecorder) UnregisterTopic 

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

UnregisterTopic indicates an expected call of UnregisterTopic.

func (*MockMetadataRepositoryClientMockRecorder) Unseal 

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

Unseal indicates an expected call of Unseal.

func (*MockMetadataRepositoryClientMockRecorder) UpdateLogStream 

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

UpdateLogStream indicates an expected call of UpdateLogStream.

type MockMetadataRepositoryManagementClient 

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

MockMetadataRepositoryManagementClient is a mock of MetadataRepositoryManagementClient interface.

func NewMockMetadataRepositoryManagementClient 

func NewMockMetadataRepositoryManagementClient(ctrl *gomock.Controller) *MockMetadataRepositoryManagementClient

NewMockMetadataRepositoryManagementClient creates a new mock instance.

func (*MockMetadataRepositoryManagementClient) AddPeer 

func (m *MockMetadataRepositoryManagementClient) AddPeer(arg0 context.Context, arg1 types.ClusterID, arg2 types.NodeID, arg3 string) error

AddPeer mocks base method.

func (*MockMetadataRepositoryManagementClient) Close 

func (m *MockMetadataRepositoryManagementClient) Close() error

Close mocks base method.

func (*MockMetadataRepositoryManagementClient) EXPECT 

func (m *MockMetadataRepositoryManagementClient) EXPECT() *MockMetadataRepositoryManagementClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMetadataRepositoryManagementClient) GetClusterInfo 

func (m *MockMetadataRepositoryManagementClient) GetClusterInfo(arg0 context.Context, arg1 types.ClusterID) (*mrpb.GetClusterInfoResponse, error)

GetClusterInfo mocks base method.

func (*MockMetadataRepositoryManagementClient) RemovePeer 

func (m *MockMetadataRepositoryManagementClient) RemovePeer(arg0 context.Context, arg1 types.ClusterID, arg2 types.NodeID) error

RemovePeer mocks base method.

type MockMetadataRepositoryManagementClientMockRecorder 

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

MockMetadataRepositoryManagementClientMockRecorder is the mock recorder for MockMetadataRepositoryManagementClient.

func (*MockMetadataRepositoryManagementClientMockRecorder) AddPeer 

func (mr *MockMetadataRepositoryManagementClientMockRecorder) AddPeer(arg0, arg1, arg2, arg3 any) *gomock.Call

AddPeer indicates an expected call of AddPeer.

func (*MockMetadataRepositoryManagementClientMockRecorder) Close 

func (mr *MockMetadataRepositoryManagementClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockMetadataRepositoryManagementClientMockRecorder) GetClusterInfo 

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

GetClusterInfo indicates an expected call of GetClusterInfo.

func (*MockMetadataRepositoryManagementClientMockRecorder) RemovePeer 

func (mr *MockMetadataRepositoryManagementClientMockRecorder) RemovePeer(arg0, arg1, arg2 any) *gomock.Call

RemovePeer indicates an expected call of RemovePeer.

Source Files

View all Source files

Directories

Path Synopsis

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.