mock

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2022 License: Apache-2.0 Imports: 7 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 MockLogIOClient 

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

MockLogIOClient is a mock of LogIOClient interface.

func NewMockLogIOClient 

func NewMockLogIOClient(ctrl *gomock.Controller) *MockLogIOClient

NewMockLogIOClient creates a new mock instance.

func (*MockLogIOClient) Append 

func (m *MockLogIOClient) Append(arg0 context.Context, arg1 *snpb.AppendRequest, arg2 ...grpc.CallOption) (*snpb.AppendResponse, error)

Append mocks base method.

func (*MockLogIOClient) EXPECT 

func (m *MockLogIOClient) EXPECT() *MockLogIOClientMockRecorder

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

func (*MockLogIOClient) LogStreamMetadata 

func (m *MockLogIOClient) LogStreamMetadata(arg0 context.Context, arg1 *snpb.LogStreamMetadataRequest, arg2 ...grpc.CallOption) (*snpb.LogStreamMetadataResponse, error)

LogStreamMetadata mocks base method.

func (*MockLogIOClient) Read 

func (m *MockLogIOClient) Read(arg0 context.Context, arg1 *snpb.ReadRequest, arg2 ...grpc.CallOption) (*snpb.ReadResponse, error)

Read mocks base method.

func (*MockLogIOClient) Subscribe 

func (m *MockLogIOClient) Subscribe(arg0 context.Context, arg1 *snpb.SubscribeRequest, arg2 ...grpc.CallOption) (snpb.LogIO_SubscribeClient, error)

Subscribe mocks base method.

func (*MockLogIOClient) SubscribeTo 

func (m *MockLogIOClient) SubscribeTo(arg0 context.Context, arg1 *snpb.SubscribeToRequest, arg2 ...grpc.CallOption) (snpb.LogIO_SubscribeToClient, error)

SubscribeTo mocks base method.

func (*MockLogIOClient) TrimDeprecated 

func (m *MockLogIOClient) TrimDeprecated(arg0 context.Context, arg1 *snpb.TrimDeprecatedRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

TrimDeprecated mocks base method.

type MockLogIOClientMockRecorder 

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

MockLogIOClientMockRecorder is the mock recorder for MockLogIOClient.

func (*MockLogIOClientMockRecorder) Append 

func (mr *MockLogIOClientMockRecorder) Append(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockLogIOClientMockRecorder) LogStreamMetadata 

func (mr *MockLogIOClientMockRecorder) LogStreamMetadata(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

LogStreamMetadata indicates an expected call of LogStreamMetadata.

func (*MockLogIOClientMockRecorder) Read 

func (mr *MockLogIOClientMockRecorder) Read(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockLogIOClientMockRecorder) Subscribe 

func (mr *MockLogIOClientMockRecorder) Subscribe(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockLogIOClientMockRecorder) SubscribeTo 

func (mr *MockLogIOClientMockRecorder) SubscribeTo(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SubscribeTo indicates an expected call of SubscribeTo.

func (*MockLogIOClientMockRecorder) TrimDeprecated 

func (mr *MockLogIOClientMockRecorder) TrimDeprecated(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

TrimDeprecated indicates an expected call of TrimDeprecated.

type MockLogIOServer 

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

MockLogIOServer is a mock of LogIOServer interface.

func NewMockLogIOServer 

func NewMockLogIOServer(ctrl *gomock.Controller) *MockLogIOServer

NewMockLogIOServer creates a new mock instance.

func (*MockLogIOServer) Append 

func (m *MockLogIOServer) Append(arg0 context.Context, arg1 *snpb.AppendRequest) (*snpb.AppendResponse, error)

Append mocks base method.

func (*MockLogIOServer) EXPECT 

func (m *MockLogIOServer) EXPECT() *MockLogIOServerMockRecorder

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

func (*MockLogIOServer) LogStreamMetadata 

func (m *MockLogIOServer) LogStreamMetadata(arg0 context.Context, arg1 *snpb.LogStreamMetadataRequest) (*snpb.LogStreamMetadataResponse, error)

LogStreamMetadata mocks base method.

func (*MockLogIOServer) Read 

func (m *MockLogIOServer) Read(arg0 context.Context, arg1 *snpb.ReadRequest) (*snpb.ReadResponse, error)

Read mocks base method.

func (*MockLogIOServer) Subscribe 

func (m *MockLogIOServer) Subscribe(arg0 *snpb.SubscribeRequest, arg1 snpb.LogIO_SubscribeServer) error

Subscribe mocks base method.

func (*MockLogIOServer) SubscribeTo 

func (m *MockLogIOServer) SubscribeTo(arg0 *snpb.SubscribeToRequest, arg1 snpb.LogIO_SubscribeToServer) error

SubscribeTo mocks base method.

func (*MockLogIOServer) TrimDeprecated 

func (m *MockLogIOServer) TrimDeprecated(arg0 context.Context, arg1 *snpb.TrimDeprecatedRequest) (*types.Empty, error)

TrimDeprecated mocks base method.

type MockLogIOServerMockRecorder 

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

MockLogIOServerMockRecorder is the mock recorder for MockLogIOServer.

func (*MockLogIOServerMockRecorder) Append 

func (mr *MockLogIOServerMockRecorder) Append(arg0, arg1 interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockLogIOServerMockRecorder) LogStreamMetadata 

func (mr *MockLogIOServerMockRecorder) LogStreamMetadata(arg0, arg1 interface{}) *gomock.Call

LogStreamMetadata indicates an expected call of LogStreamMetadata.

func (*MockLogIOServerMockRecorder) Read 

func (mr *MockLogIOServerMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockLogIOServerMockRecorder) Subscribe 

func (mr *MockLogIOServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockLogIOServerMockRecorder) SubscribeTo 

func (mr *MockLogIOServerMockRecorder) SubscribeTo(arg0, arg1 interface{}) *gomock.Call

SubscribeTo indicates an expected call of SubscribeTo.

func (*MockLogIOServerMockRecorder) TrimDeprecated 

func (mr *MockLogIOServerMockRecorder) TrimDeprecated(arg0, arg1 interface{}) *gomock.Call

TrimDeprecated indicates an expected call of TrimDeprecated.

type MockLogIO_SubscribeClient 

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

MockLogIO_SubscribeClient is a mock of LogIO_SubscribeClient interface.

func NewMockLogIO_SubscribeClient 

func NewMockLogIO_SubscribeClient(ctrl *gomock.Controller) *MockLogIO_SubscribeClient

NewMockLogIO_SubscribeClient creates a new mock instance.

func (*MockLogIO_SubscribeClient) CloseSend 

func (m *MockLogIO_SubscribeClient) CloseSend() error

CloseSend mocks base method.

func (*MockLogIO_SubscribeClient) Context 

func (m *MockLogIO_SubscribeClient) Context() context.Context

Context mocks base method.

func (*MockLogIO_SubscribeClient) EXPECT 

func (m *MockLogIO_SubscribeClient) EXPECT() *MockLogIO_SubscribeClientMockRecorder

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

func (*MockLogIO_SubscribeClient) Header 

func (m *MockLogIO_SubscribeClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockLogIO_SubscribeClient) Recv 

func (m *MockLogIO_SubscribeClient) Recv() (*snpb.SubscribeResponse, error)

Recv mocks base method.

func (*MockLogIO_SubscribeClient) RecvMsg 

func (m *MockLogIO_SubscribeClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockLogIO_SubscribeClient) SendMsg 

func (m *MockLogIO_SubscribeClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockLogIO_SubscribeClient) Trailer 

func (m *MockLogIO_SubscribeClient) Trailer() metadata.MD

Trailer mocks base method.

type MockLogIO_SubscribeClientMockRecorder 

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

MockLogIO_SubscribeClientMockRecorder is the mock recorder for MockLogIO_SubscribeClient.

func (*MockLogIO_SubscribeClientMockRecorder) CloseSend 

func (mr *MockLogIO_SubscribeClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockLogIO_SubscribeClientMockRecorder) Context 

func (mr *MockLogIO_SubscribeClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockLogIO_SubscribeClientMockRecorder) Header 

func (mr *MockLogIO_SubscribeClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockLogIO_SubscribeClientMockRecorder) Recv 

func (mr *MockLogIO_SubscribeClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockLogIO_SubscribeClientMockRecorder) RecvMsg 

func (mr *MockLogIO_SubscribeClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockLogIO_SubscribeClientMockRecorder) SendMsg 

func (mr *MockLogIO_SubscribeClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockLogIO_SubscribeClientMockRecorder) Trailer 

func (mr *MockLogIO_SubscribeClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockLogIO_SubscribeServer 

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

MockLogIO_SubscribeServer is a mock of LogIO_SubscribeServer interface.

func NewMockLogIO_SubscribeServer 

func NewMockLogIO_SubscribeServer(ctrl *gomock.Controller) *MockLogIO_SubscribeServer

NewMockLogIO_SubscribeServer creates a new mock instance.

func (*MockLogIO_SubscribeServer) Context 

func (m *MockLogIO_SubscribeServer) Context() context.Context

Context mocks base method.

func (*MockLogIO_SubscribeServer) EXPECT 

func (m *MockLogIO_SubscribeServer) EXPECT() *MockLogIO_SubscribeServerMockRecorder

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

func (*MockLogIO_SubscribeServer) RecvMsg 

func (m *MockLogIO_SubscribeServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockLogIO_SubscribeServer) Send 

func (m *MockLogIO_SubscribeServer) Send(arg0 *snpb.SubscribeResponse) error

Send mocks base method.

func (*MockLogIO_SubscribeServer) SendHeader 

func (m *MockLogIO_SubscribeServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockLogIO_SubscribeServer) SendMsg 

func (m *MockLogIO_SubscribeServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockLogIO_SubscribeServer) SetHeader 

func (m *MockLogIO_SubscribeServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockLogIO_SubscribeServer) SetTrailer 

func (m *MockLogIO_SubscribeServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockLogIO_SubscribeServerMockRecorder 

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

MockLogIO_SubscribeServerMockRecorder is the mock recorder for MockLogIO_SubscribeServer.

func (*MockLogIO_SubscribeServerMockRecorder) Context 

func (mr *MockLogIO_SubscribeServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockLogIO_SubscribeServerMockRecorder) RecvMsg 

func (mr *MockLogIO_SubscribeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockLogIO_SubscribeServerMockRecorder) Send 

func (mr *MockLogIO_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockLogIO_SubscribeServerMockRecorder) SendHeader 

func (mr *MockLogIO_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockLogIO_SubscribeServerMockRecorder) SendMsg 

func (mr *MockLogIO_SubscribeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockLogIO_SubscribeServerMockRecorder) SetHeader 

func (mr *MockLogIO_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockLogIO_SubscribeServerMockRecorder) SetTrailer 

func (mr *MockLogIO_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockLogStreamReporterClient 

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

MockLogStreamReporterClient is a mock of LogStreamReporterClient interface.

func NewMockLogStreamReporterClient 

func NewMockLogStreamReporterClient(ctrl *gomock.Controller) *MockLogStreamReporterClient

NewMockLogStreamReporterClient creates a new mock instance.

func (*MockLogStreamReporterClient) Commit 

func (m *MockLogStreamReporterClient) Commit(arg0 context.Context, arg1 ...grpc.CallOption) (snpb.LogStreamReporter_CommitClient, error)

Commit mocks base method.

func (*MockLogStreamReporterClient) EXPECT 

func (m *MockLogStreamReporterClient) EXPECT() *MockLogStreamReporterClientMockRecorder

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

func (*MockLogStreamReporterClient) GetReport 

func (m *MockLogStreamReporterClient) GetReport(arg0 context.Context, arg1 ...grpc.CallOption) (snpb.LogStreamReporter_GetReportClient, error)

GetReport mocks base method.

type MockLogStreamReporterClientMockRecorder 

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

MockLogStreamReporterClientMockRecorder is the mock recorder for MockLogStreamReporterClient.

func (*MockLogStreamReporterClientMockRecorder) Commit 

func (mr *MockLogStreamReporterClientMockRecorder) Commit(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Commit indicates an expected call of Commit.

func (*MockLogStreamReporterClientMockRecorder) GetReport 

func (mr *MockLogStreamReporterClientMockRecorder) GetReport(arg0 interface{}, arg1 ...interface{}) *gomock.Call

GetReport indicates an expected call of GetReport.

type MockLogStreamReporterServer 

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

MockLogStreamReporterServer is a mock of LogStreamReporterServer interface.

func NewMockLogStreamReporterServer 

func NewMockLogStreamReporterServer(ctrl *gomock.Controller) *MockLogStreamReporterServer

NewMockLogStreamReporterServer creates a new mock instance.

func (*MockLogStreamReporterServer) Commit 

func (m *MockLogStreamReporterServer) Commit(arg0 snpb.LogStreamReporter_CommitServer) error

Commit mocks base method.

func (*MockLogStreamReporterServer) EXPECT 

func (m *MockLogStreamReporterServer) EXPECT() *MockLogStreamReporterServerMockRecorder

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

func (*MockLogStreamReporterServer) GetReport 

func (m *MockLogStreamReporterServer) GetReport(arg0 snpb.LogStreamReporter_GetReportServer) error

GetReport mocks base method.

type MockLogStreamReporterServerMockRecorder 

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

MockLogStreamReporterServerMockRecorder is the mock recorder for MockLogStreamReporterServer.

func (*MockLogStreamReporterServerMockRecorder) Commit 

func (mr *MockLogStreamReporterServerMockRecorder) Commit(arg0 interface{}) *gomock.Call

Commit indicates an expected call of Commit.

func (*MockLogStreamReporterServerMockRecorder) GetReport 

func (mr *MockLogStreamReporterServerMockRecorder) GetReport(arg0 interface{}) *gomock.Call

GetReport indicates an expected call of GetReport.

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

func (m *MockManagementClient) AddLogStreamReplica(arg0 context.Context, arg1 *snpb.AddLogStreamReplicaRequest, arg2 ...grpc.CallOption) (*snpb.AddLogStreamReplicaResponse, error)

AddLogStreamReplica 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) GetMetadata 

func (m *MockManagementClient) GetMetadata(arg0 context.Context, arg1 *snpb.GetMetadataRequest, arg2 ...grpc.CallOption) (*snpb.GetMetadataResponse, error)

GetMetadata mocks base method.

func (*MockManagementClient) RemoveLogStream 

func (m *MockManagementClient) RemoveLogStream(arg0 context.Context, arg1 *snpb.RemoveLogStreamRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

RemoveLogStream mocks base method.

func (*MockManagementClient) Seal 

func (m *MockManagementClient) Seal(arg0 context.Context, arg1 *snpb.SealRequest, arg2 ...grpc.CallOption) (*snpb.SealResponse, error)

Seal mocks base method.

func (*MockManagementClient) Sync 

func (m *MockManagementClient) Sync(arg0 context.Context, arg1 *snpb.SyncRequest, arg2 ...grpc.CallOption) (*snpb.SyncResponse, error)

Sync mocks base method.

func (*MockManagementClient) Trim 

func (m *MockManagementClient) Trim(arg0 context.Context, arg1 *snpb.TrimRequest, arg2 ...grpc.CallOption) (*snpb.TrimResponse, error)

Trim mocks base method.

func (*MockManagementClient) Unseal 

func (m *MockManagementClient) Unseal(arg0 context.Context, arg1 *snpb.UnsealRequest, arg2 ...grpc.CallOption) (*types.Empty, error)

Unseal mocks base method.

type MockManagementClientMockRecorder 

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

MockManagementClientMockRecorder is the mock recorder for MockManagementClient.

func (*MockManagementClientMockRecorder) AddLogStreamReplica 

func (mr *MockManagementClientMockRecorder) AddLogStreamReplica(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

AddLogStreamReplica indicates an expected call of AddLogStreamReplica.

func (*MockManagementClientMockRecorder) GetMetadata 

func (mr *MockManagementClientMockRecorder) GetMetadata(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockManagementClientMockRecorder) RemoveLogStream 

func (mr *MockManagementClientMockRecorder) RemoveLogStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RemoveLogStream indicates an expected call of RemoveLogStream.

func (*MockManagementClientMockRecorder) Seal 

func (mr *MockManagementClientMockRecorder) Seal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockManagementClientMockRecorder) Sync 

func (mr *MockManagementClientMockRecorder) Sync(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Sync indicates an expected call of Sync.

func (*MockManagementClientMockRecorder) Trim 

func (mr *MockManagementClientMockRecorder) Trim(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Trim indicates an expected call of Trim.

func (*MockManagementClientMockRecorder) Unseal 

func (mr *MockManagementClientMockRecorder) Unseal(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Unseal indicates an expected call of Unseal.

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

func (m *MockManagementServer) AddLogStreamReplica(arg0 context.Context, arg1 *snpb.AddLogStreamReplicaRequest) (*snpb.AddLogStreamReplicaResponse, error)

AddLogStreamReplica 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) GetMetadata 

func (m *MockManagementServer) GetMetadata(arg0 context.Context, arg1 *snpb.GetMetadataRequest) (*snpb.GetMetadataResponse, error)

GetMetadata mocks base method.

func (*MockManagementServer) RemoveLogStream 

func (m *MockManagementServer) RemoveLogStream(arg0 context.Context, arg1 *snpb.RemoveLogStreamRequest) (*types.Empty, error)

RemoveLogStream mocks base method.

func (*MockManagementServer) Seal 

func (m *MockManagementServer) Seal(arg0 context.Context, arg1 *snpb.SealRequest) (*snpb.SealResponse, error)

Seal mocks base method.

func (*MockManagementServer) Sync 

func (m *MockManagementServer) Sync(arg0 context.Context, arg1 *snpb.SyncRequest) (*snpb.SyncResponse, error)

Sync mocks base method.

func (*MockManagementServer) Trim 

func (m *MockManagementServer) Trim(arg0 context.Context, arg1 *snpb.TrimRequest) (*snpb.TrimResponse, error)

Trim mocks base method.

func (*MockManagementServer) Unseal 

func (m *MockManagementServer) Unseal(arg0 context.Context, arg1 *snpb.UnsealRequest) (*types.Empty, error)

Unseal mocks base method.

type MockManagementServerMockRecorder 

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

MockManagementServerMockRecorder is the mock recorder for MockManagementServer.

func (*MockManagementServerMockRecorder) AddLogStreamReplica 

func (mr *MockManagementServerMockRecorder) AddLogStreamReplica(arg0, arg1 interface{}) *gomock.Call

AddLogStreamReplica indicates an expected call of AddLogStreamReplica.

func (*MockManagementServerMockRecorder) GetMetadata 

func (mr *MockManagementServerMockRecorder) GetMetadata(arg0, arg1 interface{}) *gomock.Call

GetMetadata indicates an expected call of GetMetadata.

func (*MockManagementServerMockRecorder) RemoveLogStream 

func (mr *MockManagementServerMockRecorder) RemoveLogStream(arg0, arg1 interface{}) *gomock.Call

RemoveLogStream indicates an expected call of RemoveLogStream.

func (*MockManagementServerMockRecorder) Seal 

func (mr *MockManagementServerMockRecorder) Seal(arg0, arg1 interface{}) *gomock.Call

Seal indicates an expected call of Seal.

func (*MockManagementServerMockRecorder) Sync 

func (mr *MockManagementServerMockRecorder) Sync(arg0, arg1 interface{}) *gomock.Call

Sync indicates an expected call of Sync.

func (*MockManagementServerMockRecorder) Trim 

func (mr *MockManagementServerMockRecorder) Trim(arg0, arg1 interface{}) *gomock.Call

Trim indicates an expected call of Trim.

func (*MockManagementServerMockRecorder) Unseal 

func (mr *MockManagementServerMockRecorder) Unseal(arg0, arg1 interface{}) *gomock.Call

Unseal indicates an expected call of Unseal.

type MockReplicatorClient 

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

MockReplicatorClient is a mock of ReplicatorClient interface.

func NewMockReplicatorClient 

func NewMockReplicatorClient(ctrl *gomock.Controller) *MockReplicatorClient

NewMockReplicatorClient creates a new mock instance.

func (*MockReplicatorClient) EXPECT 

func (m *MockReplicatorClient) EXPECT() *MockReplicatorClientMockRecorder

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

func (*MockReplicatorClient) Replicate 

func (m *MockReplicatorClient) Replicate(arg0 context.Context, arg1 ...grpc.CallOption) (snpb.Replicator_ReplicateClient, error)

Replicate mocks base method.

func (*MockReplicatorClient) ReplicateDeprecated 

func (m *MockReplicatorClient) ReplicateDeprecated(arg0 context.Context, arg1 ...grpc.CallOption) (snpb.Replicator_ReplicateDeprecatedClient, error)

ReplicateDeprecated mocks base method.

func (*MockReplicatorClient) SyncInit 

func (m *MockReplicatorClient) SyncInit(arg0 context.Context, arg1 *snpb.SyncInitRequest, arg2 ...grpc.CallOption) (*snpb.SyncInitResponse, error)

SyncInit mocks base method.

func (*MockReplicatorClient) SyncReplicate 

func (m *MockReplicatorClient) SyncReplicate(arg0 context.Context, arg1 *snpb.SyncReplicateRequest, arg2 ...grpc.CallOption) (*snpb.SyncReplicateResponse, error)

SyncReplicate mocks base method.

type MockReplicatorClientMockRecorder 

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

MockReplicatorClientMockRecorder is the mock recorder for MockReplicatorClient.

func (*MockReplicatorClientMockRecorder) Replicate 

func (mr *MockReplicatorClientMockRecorder) Replicate(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Replicate indicates an expected call of Replicate.

func (*MockReplicatorClientMockRecorder) ReplicateDeprecated 

func (mr *MockReplicatorClientMockRecorder) ReplicateDeprecated(arg0 interface{}, arg1 ...interface{}) *gomock.Call

ReplicateDeprecated indicates an expected call of ReplicateDeprecated.

func (*MockReplicatorClientMockRecorder) SyncInit 

func (mr *MockReplicatorClientMockRecorder) SyncInit(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SyncInit indicates an expected call of SyncInit.

func (*MockReplicatorClientMockRecorder) SyncReplicate 

func (mr *MockReplicatorClientMockRecorder) SyncReplicate(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

SyncReplicate indicates an expected call of SyncReplicate.

type MockReplicatorServer 

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

MockReplicatorServer is a mock of ReplicatorServer interface.

func NewMockReplicatorServer 

func NewMockReplicatorServer(ctrl *gomock.Controller) *MockReplicatorServer

NewMockReplicatorServer creates a new mock instance.

func (*MockReplicatorServer) EXPECT 

func (m *MockReplicatorServer) EXPECT() *MockReplicatorServerMockRecorder

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

func (*MockReplicatorServer) Replicate 

func (m *MockReplicatorServer) Replicate(arg0 snpb.Replicator_ReplicateServer) error

Replicate mocks base method.

func (*MockReplicatorServer) ReplicateDeprecated 

func (m *MockReplicatorServer) ReplicateDeprecated(arg0 snpb.Replicator_ReplicateDeprecatedServer) error

ReplicateDeprecated mocks base method.

func (*MockReplicatorServer) SyncInit 

func (m *MockReplicatorServer) SyncInit(arg0 context.Context, arg1 *snpb.SyncInitRequest) (*snpb.SyncInitResponse, error)

SyncInit mocks base method.

func (*MockReplicatorServer) SyncReplicate 

func (m *MockReplicatorServer) SyncReplicate(arg0 context.Context, arg1 *snpb.SyncReplicateRequest) (*snpb.SyncReplicateResponse, error)

SyncReplicate mocks base method.

type MockReplicatorServerMockRecorder 

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

MockReplicatorServerMockRecorder is the mock recorder for MockReplicatorServer.

func (*MockReplicatorServerMockRecorder) Replicate 

func (mr *MockReplicatorServerMockRecorder) Replicate(arg0 interface{}) *gomock.Call

Replicate indicates an expected call of Replicate.

func (*MockReplicatorServerMockRecorder) ReplicateDeprecated 

func (mr *MockReplicatorServerMockRecorder) ReplicateDeprecated(arg0 interface{}) *gomock.Call

ReplicateDeprecated indicates an expected call of ReplicateDeprecated.

func (*MockReplicatorServerMockRecorder) SyncInit 

func (mr *MockReplicatorServerMockRecorder) SyncInit(arg0, arg1 interface{}) *gomock.Call

SyncInit indicates an expected call of SyncInit.

func (*MockReplicatorServerMockRecorder) SyncReplicate 

func (mr *MockReplicatorServerMockRecorder) SyncReplicate(arg0, arg1 interface{}) *gomock.Call

SyncReplicate indicates an expected call of SyncReplicate.

type MockReplicator_ReplicateClient 

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

MockReplicator_ReplicateClient is a mock of Replicator_ReplicateClient interface.

func NewMockReplicator_ReplicateClient 

func NewMockReplicator_ReplicateClient(ctrl *gomock.Controller) *MockReplicator_ReplicateClient

NewMockReplicator_ReplicateClient creates a new mock instance.

func (*MockReplicator_ReplicateClient) CloseAndRecv 

func (m *MockReplicator_ReplicateClient) CloseAndRecv() (*snpb.ReplicateResponse, error)

CloseAndRecv mocks base method.

func (*MockReplicator_ReplicateClient) CloseSend 

func (m *MockReplicator_ReplicateClient) CloseSend() error

CloseSend mocks base method.

func (*MockReplicator_ReplicateClient) Context 

func (m *MockReplicator_ReplicateClient) Context() context.Context

Context mocks base method.

func (*MockReplicator_ReplicateClient) EXPECT 

func (m *MockReplicator_ReplicateClient) EXPECT() *MockReplicator_ReplicateClientMockRecorder

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

func (*MockReplicator_ReplicateClient) Header 

func (m *MockReplicator_ReplicateClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockReplicator_ReplicateClient) RecvMsg 

func (m *MockReplicator_ReplicateClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockReplicator_ReplicateClient) Send 

func (m *MockReplicator_ReplicateClient) Send(arg0 *snpb.ReplicateRequest) error

Send mocks base method.

func (*MockReplicator_ReplicateClient) SendMsg 

func (m *MockReplicator_ReplicateClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockReplicator_ReplicateClient) Trailer 

func (m *MockReplicator_ReplicateClient) Trailer() metadata.MD

Trailer mocks base method.

type MockReplicator_ReplicateClientMockRecorder 

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

MockReplicator_ReplicateClientMockRecorder is the mock recorder for MockReplicator_ReplicateClient.

func (*MockReplicator_ReplicateClientMockRecorder) CloseAndRecv 

func (mr *MockReplicator_ReplicateClientMockRecorder) CloseAndRecv() *gomock.Call

CloseAndRecv indicates an expected call of CloseAndRecv.

func (*MockReplicator_ReplicateClientMockRecorder) CloseSend 

func (mr *MockReplicator_ReplicateClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockReplicator_ReplicateClientMockRecorder) Context 

func (mr *MockReplicator_ReplicateClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockReplicator_ReplicateClientMockRecorder) Header 

func (mr *MockReplicator_ReplicateClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockReplicator_ReplicateClientMockRecorder) RecvMsg 

func (mr *MockReplicator_ReplicateClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockReplicator_ReplicateClientMockRecorder) Send 

func (mr *MockReplicator_ReplicateClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockReplicator_ReplicateClientMockRecorder) SendMsg 

func (mr *MockReplicator_ReplicateClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockReplicator_ReplicateClientMockRecorder) Trailer 

func (mr *MockReplicator_ReplicateClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockReplicator_ReplicateDeprecatedClient 

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

MockReplicator_ReplicateDeprecatedClient is a mock of Replicator_ReplicateDeprecatedClient interface.

func NewMockReplicator_ReplicateDeprecatedClient 

func NewMockReplicator_ReplicateDeprecatedClient(ctrl *gomock.Controller) *MockReplicator_ReplicateDeprecatedClient

NewMockReplicator_ReplicateDeprecatedClient creates a new mock instance.

func (*MockReplicator_ReplicateDeprecatedClient) CloseSend 

func (m *MockReplicator_ReplicateDeprecatedClient) CloseSend() error

CloseSend mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) Context 

func (m *MockReplicator_ReplicateDeprecatedClient) Context() context.Context

Context mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) EXPECT 

func (m *MockReplicator_ReplicateDeprecatedClient) EXPECT() *MockReplicator_ReplicateDeprecatedClientMockRecorder

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

func (*MockReplicator_ReplicateDeprecatedClient) Header 

func (m *MockReplicator_ReplicateDeprecatedClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) Recv 

func (m *MockReplicator_ReplicateDeprecatedClient) Recv() (*snpb.ReplicationResponse, error)

Recv mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) RecvMsg 

func (m *MockReplicator_ReplicateDeprecatedClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) Send 

func (m *MockReplicator_ReplicateDeprecatedClient) Send(arg0 *snpb.ReplicationRequest) error

Send mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) SendMsg 

func (m *MockReplicator_ReplicateDeprecatedClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockReplicator_ReplicateDeprecatedClient) Trailer 

func (m *MockReplicator_ReplicateDeprecatedClient) Trailer() metadata.MD

Trailer mocks base method.

type MockReplicator_ReplicateDeprecatedClientMockRecorder 

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

MockReplicator_ReplicateDeprecatedClientMockRecorder is the mock recorder for MockReplicator_ReplicateDeprecatedClient.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) CloseSend 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) Context 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) Header 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) Recv 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) RecvMsg 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) Send 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) SendMsg 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockReplicator_ReplicateDeprecatedClientMockRecorder) Trailer 

func (mr *MockReplicator_ReplicateDeprecatedClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockReplicator_ReplicateDeprecatedServer 

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

MockReplicator_ReplicateDeprecatedServer is a mock of Replicator_ReplicateDeprecatedServer interface.

func NewMockReplicator_ReplicateDeprecatedServer 

func NewMockReplicator_ReplicateDeprecatedServer(ctrl *gomock.Controller) *MockReplicator_ReplicateDeprecatedServer

NewMockReplicator_ReplicateDeprecatedServer creates a new mock instance.

func (*MockReplicator_ReplicateDeprecatedServer) Context 

func (m *MockReplicator_ReplicateDeprecatedServer) Context() context.Context

Context mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) EXPECT 

func (m *MockReplicator_ReplicateDeprecatedServer) EXPECT() *MockReplicator_ReplicateDeprecatedServerMockRecorder

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

func (*MockReplicator_ReplicateDeprecatedServer) Recv 

func (m *MockReplicator_ReplicateDeprecatedServer) Recv() (*snpb.ReplicationRequest, error)

Recv mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) RecvMsg 

func (m *MockReplicator_ReplicateDeprecatedServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) Send 

func (m *MockReplicator_ReplicateDeprecatedServer) Send(arg0 *snpb.ReplicationResponse) error

Send mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) SendHeader 

func (m *MockReplicator_ReplicateDeprecatedServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) SendMsg 

func (m *MockReplicator_ReplicateDeprecatedServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) SetHeader 

func (m *MockReplicator_ReplicateDeprecatedServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockReplicator_ReplicateDeprecatedServer) SetTrailer 

func (m *MockReplicator_ReplicateDeprecatedServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockReplicator_ReplicateDeprecatedServerMockRecorder 

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

MockReplicator_ReplicateDeprecatedServerMockRecorder is the mock recorder for MockReplicator_ReplicateDeprecatedServer.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) Context 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) Recv 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) RecvMsg 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) Send 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) SendHeader 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) SendMsg 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) SetHeader 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockReplicator_ReplicateDeprecatedServerMockRecorder) SetTrailer 

func (mr *MockReplicator_ReplicateDeprecatedServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

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.