mocks

package
v2.0.166 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockSchedulerClient 

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

MockSchedulerClient is a mock of SchedulerClient interface.

func NewMockSchedulerClient 

func NewMockSchedulerClient(ctrl *gomock.Controller) *MockSchedulerClient

NewMockSchedulerClient creates a new mock instance.

func (*MockSchedulerClient) AnnounceHost 

func (m *MockSchedulerClient) AnnounceHost(ctx context.Context, in *scheduler.AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

AnnounceHost mocks base method.

func (*MockSchedulerClient) AnnouncePeer 

func (m *MockSchedulerClient) AnnouncePeer(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_AnnouncePeerClient, error)

AnnouncePeer mocks base method.

func (*MockSchedulerClient) AnnouncePersistentCachePeer added in v2.0.162 

func (m *MockSchedulerClient) AnnouncePersistentCachePeer(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_AnnouncePersistentCachePeerClient, error)

AnnouncePersistentCachePeer mocks base method.

func (*MockSchedulerClient) DeleteHost added in v2.0.120 

func (m *MockSchedulerClient) DeleteHost(ctx context.Context, in *scheduler.DeleteHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteHost mocks base method.

func (*MockSchedulerClient) DeletePeer added in v2.0.120 

func (m *MockSchedulerClient) DeletePeer(ctx context.Context, in *scheduler.DeletePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeletePeer mocks base method.

func (*MockSchedulerClient) DeletePersistentCachePeer added in v2.0.162 

func (m *MockSchedulerClient) DeletePersistentCachePeer(ctx context.Context, in *scheduler.DeletePersistentCachePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeletePersistentCachePeer mocks base method.

func (*MockSchedulerClient) DeletePersistentCacheTask added in v2.0.162 

func (m *MockSchedulerClient) DeletePersistentCacheTask(ctx context.Context, in *scheduler.DeletePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeletePersistentCacheTask mocks base method.

func (*MockSchedulerClient) DeleteTask added in v2.0.120 

func (m *MockSchedulerClient) DeleteTask(ctx context.Context, in *scheduler.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

DeleteTask mocks base method.

func (*MockSchedulerClient) EXPECT 

func (m *MockSchedulerClient) EXPECT() *MockSchedulerClientMockRecorder

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

func (*MockSchedulerClient) ListHosts added in v2.0.158 

func (m *MockSchedulerClient) ListHosts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*scheduler.ListHostsResponse, error)

ListHosts mocks base method.

func (*MockSchedulerClient) StatPeer 

func (m *MockSchedulerClient) StatPeer(ctx context.Context, in *scheduler.StatPeerRequest, opts ...grpc.CallOption) (*common.Peer, error)

StatPeer mocks base method.

func (*MockSchedulerClient) StatPersistentCachePeer added in v2.0.162 

func (m *MockSchedulerClient) StatPersistentCachePeer(ctx context.Context, in *scheduler.StatPersistentCachePeerRequest, opts ...grpc.CallOption) (*common.PersistentCachePeer, error)

StatPersistentCachePeer mocks base method.

func (*MockSchedulerClient) StatPersistentCacheTask added in v2.0.162 

func (m *MockSchedulerClient) StatPersistentCacheTask(ctx context.Context, in *scheduler.StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*common.PersistentCacheTask, error)

StatPersistentCacheTask mocks base method.

func (*MockSchedulerClient) StatTask 

func (m *MockSchedulerClient) StatTask(ctx context.Context, in *scheduler.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)

StatTask mocks base method.

func (*MockSchedulerClient) UploadPersistentCacheTaskFailed added in v2.0.162 

func (m *MockSchedulerClient) UploadPersistentCacheTaskFailed(ctx context.Context, in *scheduler.UploadPersistentCacheTaskFailedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

UploadPersistentCacheTaskFailed mocks base method.

func (*MockSchedulerClient) UploadPersistentCacheTaskFinished added in v2.0.162 

func (m *MockSchedulerClient) UploadPersistentCacheTaskFinished(ctx context.Context, in *scheduler.UploadPersistentCacheTaskFinishedRequest, opts ...grpc.CallOption) (*common.PersistentCacheTask, error)

UploadPersistentCacheTaskFinished mocks base method.

func (*MockSchedulerClient) UploadPersistentCacheTaskStarted added in v2.0.162 

func (m *MockSchedulerClient) UploadPersistentCacheTaskStarted(ctx context.Context, in *scheduler.UploadPersistentCacheTaskStartedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

UploadPersistentCacheTaskStarted mocks base method.

type MockSchedulerClientMockRecorder 

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

MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.

func (*MockSchedulerClientMockRecorder) AnnounceHost 

func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in any, opts ...any) *gomock.Call

AnnounceHost indicates an expected call of AnnounceHost.

func (*MockSchedulerClientMockRecorder) AnnouncePeer 

func (mr *MockSchedulerClientMockRecorder) AnnouncePeer(ctx any, opts ...any) *gomock.Call

AnnouncePeer indicates an expected call of AnnouncePeer.

func (*MockSchedulerClientMockRecorder) AnnouncePersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) AnnouncePersistentCachePeer(ctx any, opts ...any) *gomock.Call

AnnouncePersistentCachePeer indicates an expected call of AnnouncePersistentCachePeer.

func (*MockSchedulerClientMockRecorder) DeleteHost added in v2.0.120 

func (mr *MockSchedulerClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call

DeleteHost indicates an expected call of DeleteHost.

func (*MockSchedulerClientMockRecorder) DeletePeer added in v2.0.120 

func (mr *MockSchedulerClientMockRecorder) DeletePeer(ctx, in any, opts ...any) *gomock.Call

DeletePeer indicates an expected call of DeletePeer.

func (*MockSchedulerClientMockRecorder) DeletePersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) DeletePersistentCachePeer(ctx, in any, opts ...any) *gomock.Call

DeletePersistentCachePeer indicates an expected call of DeletePersistentCachePeer.

func (*MockSchedulerClientMockRecorder) DeletePersistentCacheTask added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call

DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.

func (*MockSchedulerClientMockRecorder) DeleteTask added in v2.0.120 

func (mr *MockSchedulerClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call

DeleteTask indicates an expected call of DeleteTask.

func (*MockSchedulerClientMockRecorder) ListHosts added in v2.0.158 

func (mr *MockSchedulerClientMockRecorder) ListHosts(ctx, in any, opts ...any) *gomock.Call

ListHosts indicates an expected call of ListHosts.

func (*MockSchedulerClientMockRecorder) StatPeer 

func (mr *MockSchedulerClientMockRecorder) StatPeer(ctx, in any, opts ...any) *gomock.Call

StatPeer indicates an expected call of StatPeer.

func (*MockSchedulerClientMockRecorder) StatPersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) StatPersistentCachePeer(ctx, in any, opts ...any) *gomock.Call

StatPersistentCachePeer indicates an expected call of StatPersistentCachePeer.

func (*MockSchedulerClientMockRecorder) StatPersistentCacheTask added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call

StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.

func (*MockSchedulerClientMockRecorder) StatTask 

func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call

StatTask indicates an expected call of StatTask.

func (*MockSchedulerClientMockRecorder) UploadPersistentCacheTaskFailed added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) UploadPersistentCacheTaskFailed(ctx, in any, opts ...any) *gomock.Call

UploadPersistentCacheTaskFailed indicates an expected call of UploadPersistentCacheTaskFailed.

func (*MockSchedulerClientMockRecorder) UploadPersistentCacheTaskFinished added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) UploadPersistentCacheTaskFinished(ctx, in any, opts ...any) *gomock.Call

UploadPersistentCacheTaskFinished indicates an expected call of UploadPersistentCacheTaskFinished.

func (*MockSchedulerClientMockRecorder) UploadPersistentCacheTaskStarted added in v2.0.162 

func (mr *MockSchedulerClientMockRecorder) UploadPersistentCacheTaskStarted(ctx, in any, opts ...any) *gomock.Call

UploadPersistentCacheTaskStarted indicates an expected call of UploadPersistentCacheTaskStarted.

type MockSchedulerServer 

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

MockSchedulerServer is a mock of SchedulerServer interface.

func NewMockSchedulerServer 

func NewMockSchedulerServer(ctrl *gomock.Controller) *MockSchedulerServer

NewMockSchedulerServer creates a new mock instance.

func (*MockSchedulerServer) AnnounceHost 

func (m *MockSchedulerServer) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest) (*emptypb.Empty, error)

AnnounceHost mocks base method.

func (*MockSchedulerServer) AnnouncePeer 

func (m *MockSchedulerServer) AnnouncePeer(arg0 scheduler.Scheduler_AnnouncePeerServer) error

AnnouncePeer mocks base method.

func (*MockSchedulerServer) AnnouncePersistentCachePeer added in v2.0.162 

func (m *MockSchedulerServer) AnnouncePersistentCachePeer(arg0 scheduler.Scheduler_AnnouncePersistentCachePeerServer) error

AnnouncePersistentCachePeer mocks base method.

func (*MockSchedulerServer) DeleteHost added in v2.0.120 

func (m *MockSchedulerServer) DeleteHost(arg0 context.Context, arg1 *scheduler.DeleteHostRequest) (*emptypb.Empty, error)

DeleteHost mocks base method.

func (*MockSchedulerServer) DeletePeer added in v2.0.120 

func (m *MockSchedulerServer) DeletePeer(arg0 context.Context, arg1 *scheduler.DeletePeerRequest) (*emptypb.Empty, error)

DeletePeer mocks base method.

func (*MockSchedulerServer) DeletePersistentCachePeer added in v2.0.162 

func (m *MockSchedulerServer) DeletePersistentCachePeer(arg0 context.Context, arg1 *scheduler.DeletePersistentCachePeerRequest) (*emptypb.Empty, error)

DeletePersistentCachePeer mocks base method.

func (*MockSchedulerServer) DeletePersistentCacheTask added in v2.0.162 

func (m *MockSchedulerServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *scheduler.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)

DeletePersistentCacheTask mocks base method.

func (*MockSchedulerServer) DeleteTask added in v2.0.120 

func (m *MockSchedulerServer) DeleteTask(arg0 context.Context, arg1 *scheduler.DeleteTaskRequest) (*emptypb.Empty, error)

DeleteTask mocks base method.

func (*MockSchedulerServer) EXPECT 

func (m *MockSchedulerServer) EXPECT() *MockSchedulerServerMockRecorder

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

func (*MockSchedulerServer) ListHosts added in v2.0.158 

func (m *MockSchedulerServer) ListHosts(arg0 context.Context, arg1 *emptypb.Empty) (*scheduler.ListHostsResponse, error)

ListHosts mocks base method.

func (*MockSchedulerServer) StatPeer 

func (m *MockSchedulerServer) StatPeer(arg0 context.Context, arg1 *scheduler.StatPeerRequest) (*common.Peer, error)

StatPeer mocks base method.

func (*MockSchedulerServer) StatPersistentCachePeer added in v2.0.162 

func (m *MockSchedulerServer) StatPersistentCachePeer(arg0 context.Context, arg1 *scheduler.StatPersistentCachePeerRequest) (*common.PersistentCachePeer, error)

StatPersistentCachePeer mocks base method.

func (*MockSchedulerServer) StatPersistentCacheTask added in v2.0.162 

func (m *MockSchedulerServer) StatPersistentCacheTask(arg0 context.Context, arg1 *scheduler.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)

StatPersistentCacheTask mocks base method.

func (*MockSchedulerServer) StatTask 

func (m *MockSchedulerServer) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest) (*common.Task, error)

StatTask mocks base method.

func (*MockSchedulerServer) UploadPersistentCacheTaskFailed added in v2.0.162 

func (m *MockSchedulerServer) UploadPersistentCacheTaskFailed(arg0 context.Context, arg1 *scheduler.UploadPersistentCacheTaskFailedRequest) (*emptypb.Empty, error)

UploadPersistentCacheTaskFailed mocks base method.

func (*MockSchedulerServer) UploadPersistentCacheTaskFinished added in v2.0.162 

func (m *MockSchedulerServer) UploadPersistentCacheTaskFinished(arg0 context.Context, arg1 *scheduler.UploadPersistentCacheTaskFinishedRequest) (*common.PersistentCacheTask, error)

UploadPersistentCacheTaskFinished mocks base method.

func (*MockSchedulerServer) UploadPersistentCacheTaskStarted added in v2.0.162 

func (m *MockSchedulerServer) UploadPersistentCacheTaskStarted(arg0 context.Context, arg1 *scheduler.UploadPersistentCacheTaskStartedRequest) (*emptypb.Empty, error)

UploadPersistentCacheTaskStarted mocks base method.

type MockSchedulerServerMockRecorder 

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

MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.

func (*MockSchedulerServerMockRecorder) AnnounceHost 

func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 any) *gomock.Call

AnnounceHost indicates an expected call of AnnounceHost.

func (*MockSchedulerServerMockRecorder) AnnouncePeer 

func (mr *MockSchedulerServerMockRecorder) AnnouncePeer(arg0 any) *gomock.Call

AnnouncePeer indicates an expected call of AnnouncePeer.

func (*MockSchedulerServerMockRecorder) AnnouncePersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) AnnouncePersistentCachePeer(arg0 any) *gomock.Call

AnnouncePersistentCachePeer indicates an expected call of AnnouncePersistentCachePeer.

func (*MockSchedulerServerMockRecorder) DeleteHost added in v2.0.120 

func (mr *MockSchedulerServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call

DeleteHost indicates an expected call of DeleteHost.

func (*MockSchedulerServerMockRecorder) DeletePeer added in v2.0.120 

func (mr *MockSchedulerServerMockRecorder) DeletePeer(arg0, arg1 any) *gomock.Call

DeletePeer indicates an expected call of DeletePeer.

func (*MockSchedulerServerMockRecorder) DeletePersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) DeletePersistentCachePeer(arg0, arg1 any) *gomock.Call

DeletePersistentCachePeer indicates an expected call of DeletePersistentCachePeer.

func (*MockSchedulerServerMockRecorder) DeletePersistentCacheTask added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call

DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.

func (*MockSchedulerServerMockRecorder) DeleteTask added in v2.0.120 

func (mr *MockSchedulerServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call

DeleteTask indicates an expected call of DeleteTask.

func (*MockSchedulerServerMockRecorder) ListHosts added in v2.0.158 

func (mr *MockSchedulerServerMockRecorder) ListHosts(arg0, arg1 any) *gomock.Call

ListHosts indicates an expected call of ListHosts.

func (*MockSchedulerServerMockRecorder) StatPeer 

func (mr *MockSchedulerServerMockRecorder) StatPeer(arg0, arg1 any) *gomock.Call

StatPeer indicates an expected call of StatPeer.

func (*MockSchedulerServerMockRecorder) StatPersistentCachePeer added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) StatPersistentCachePeer(arg0, arg1 any) *gomock.Call

StatPersistentCachePeer indicates an expected call of StatPersistentCachePeer.

func (*MockSchedulerServerMockRecorder) StatPersistentCacheTask added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call

StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.

func (*MockSchedulerServerMockRecorder) StatTask 

func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call

StatTask indicates an expected call of StatTask.

func (*MockSchedulerServerMockRecorder) UploadPersistentCacheTaskFailed added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) UploadPersistentCacheTaskFailed(arg0, arg1 any) *gomock.Call

UploadPersistentCacheTaskFailed indicates an expected call of UploadPersistentCacheTaskFailed.

func (*MockSchedulerServerMockRecorder) UploadPersistentCacheTaskFinished added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) UploadPersistentCacheTaskFinished(arg0, arg1 any) *gomock.Call

UploadPersistentCacheTaskFinished indicates an expected call of UploadPersistentCacheTaskFinished.

func (*MockSchedulerServerMockRecorder) UploadPersistentCacheTaskStarted added in v2.0.162 

func (mr *MockSchedulerServerMockRecorder) UploadPersistentCacheTaskStarted(arg0, arg1 any) *gomock.Call

UploadPersistentCacheTaskStarted indicates an expected call of UploadPersistentCacheTaskStarted.

type MockScheduler_AnnouncePeerClient 

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

MockScheduler_AnnouncePeerClient is a mock of Scheduler_AnnouncePeerClient interface.

func NewMockScheduler_AnnouncePeerClient 

func NewMockScheduler_AnnouncePeerClient(ctrl *gomock.Controller) *MockScheduler_AnnouncePeerClient

NewMockScheduler_AnnouncePeerClient creates a new mock instance.

func (*MockScheduler_AnnouncePeerClient) CloseSend 

func (m *MockScheduler_AnnouncePeerClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_AnnouncePeerClient) Context 

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

Context mocks base method.

func (*MockScheduler_AnnouncePeerClient) EXPECT 

func (m *MockScheduler_AnnouncePeerClient) EXPECT() *MockScheduler_AnnouncePeerClientMockRecorder

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

func (*MockScheduler_AnnouncePeerClient) Header 

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

Header mocks base method.

func (*MockScheduler_AnnouncePeerClient) Recv 

func (m *MockScheduler_AnnouncePeerClient) Recv() (*scheduler.AnnouncePeerResponse, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePeerClient) RecvMsg 

func (m_2 *MockScheduler_AnnouncePeerClient) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePeerClient) Send 

func (m *MockScheduler_AnnouncePeerClient) Send(arg0 *scheduler.AnnouncePeerRequest) error

Send mocks base method.

func (*MockScheduler_AnnouncePeerClient) SendMsg 

func (m_2 *MockScheduler_AnnouncePeerClient) SendMsg(m any) error

SendMsg mocks base method.

func (*MockScheduler_AnnouncePeerClient) Trailer 

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

Trailer mocks base method.

type MockScheduler_AnnouncePeerClientMockRecorder 

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

MockScheduler_AnnouncePeerClientMockRecorder is the mock recorder for MockScheduler_AnnouncePeerClient.

func (*MockScheduler_AnnouncePeerClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_AnnouncePeerClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePeerClientMockRecorder) Header 

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

Header indicates an expected call of Header.

func (*MockScheduler_AnnouncePeerClientMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePeerClientMockRecorder) RecvMsg 

func (mr *MockScheduler_AnnouncePeerClientMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePeerClientMockRecorder) Send 

func (mr *MockScheduler_AnnouncePeerClientMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePeerClientMockRecorder) SendMsg 

func (mr *MockScheduler_AnnouncePeerClientMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePeerClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_AnnouncePeerServer 

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

MockScheduler_AnnouncePeerServer is a mock of Scheduler_AnnouncePeerServer interface.

func NewMockScheduler_AnnouncePeerServer 

func NewMockScheduler_AnnouncePeerServer(ctrl *gomock.Controller) *MockScheduler_AnnouncePeerServer

NewMockScheduler_AnnouncePeerServer creates a new mock instance.

func (*MockScheduler_AnnouncePeerServer) Context 

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

Context mocks base method.

func (*MockScheduler_AnnouncePeerServer) EXPECT 

func (m *MockScheduler_AnnouncePeerServer) EXPECT() *MockScheduler_AnnouncePeerServerMockRecorder

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

func (*MockScheduler_AnnouncePeerServer) Recv 

func (m *MockScheduler_AnnouncePeerServer) Recv() (*scheduler.AnnouncePeerRequest, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePeerServer) RecvMsg 

func (m_2 *MockScheduler_AnnouncePeerServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePeerServer) Send 

func (m *MockScheduler_AnnouncePeerServer) Send(arg0 *scheduler.AnnouncePeerResponse) error

Send mocks base method.

func (*MockScheduler_AnnouncePeerServer) SendHeader 

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

SendHeader mocks base method.

func (*MockScheduler_AnnouncePeerServer) SendMsg 

func (m_2 *MockScheduler_AnnouncePeerServer) SendMsg(m any) error

SendMsg mocks base method.

func (*MockScheduler_AnnouncePeerServer) SetHeader 

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

SetHeader mocks base method.

func (*MockScheduler_AnnouncePeerServer) SetTrailer 

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

SetTrailer mocks base method.

type MockScheduler_AnnouncePeerServerMockRecorder 

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

MockScheduler_AnnouncePeerServerMockRecorder is the mock recorder for MockScheduler_AnnouncePeerServer.

func (*MockScheduler_AnnouncePeerServerMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePeerServerMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePeerServerMockRecorder) RecvMsg 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePeerServerMockRecorder) Send 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePeerServerMockRecorder) SendHeader 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendHeader(arg0 any) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_AnnouncePeerServerMockRecorder) SendMsg 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePeerServerMockRecorder) SetHeader 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetHeader(arg0 any) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_AnnouncePeerServerMockRecorder) SetTrailer 

func (mr *MockScheduler_AnnouncePeerServerMockRecorder) SetTrailer(arg0 any) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockScheduler_AnnouncePersistentCachePeerClient added in v2.0.162 

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

MockScheduler_AnnouncePersistentCachePeerClient is a mock of Scheduler_AnnouncePersistentCachePeerClient interface.

func NewMockScheduler_AnnouncePersistentCachePeerClient added in v2.0.162 

func NewMockScheduler_AnnouncePersistentCachePeerClient(ctrl *gomock.Controller) *MockScheduler_AnnouncePersistentCachePeerClient

NewMockScheduler_AnnouncePersistentCachePeerClient creates a new mock instance.

func (*MockScheduler_AnnouncePersistentCachePeerClient) CloseSend added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) Context added in v2.0.162 

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

Context mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) EXPECT added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerClient) EXPECT() *MockScheduler_AnnouncePersistentCachePeerClientMockRecorder

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

func (*MockScheduler_AnnouncePersistentCachePeerClient) Header added in v2.0.162 

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

Header mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) Recv added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerClient) Recv() (*scheduler.AnnouncePersistentCachePeerResponse, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) RecvMsg added in v2.0.162 

func (m_2 *MockScheduler_AnnouncePersistentCachePeerClient) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) Send added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerClient) Send(arg0 *scheduler.AnnouncePersistentCachePeerRequest) error

Send mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) SendMsg added in v2.0.162 

func (m_2 *MockScheduler_AnnouncePersistentCachePeerClient) SendMsg(m any) error

SendMsg mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerClient) Trailer added in v2.0.162 

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

Trailer mocks base method.

type MockScheduler_AnnouncePersistentCachePeerClientMockRecorder added in v2.0.162 

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

MockScheduler_AnnouncePersistentCachePeerClientMockRecorder is the mock recorder for MockScheduler_AnnouncePersistentCachePeerClient.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) CloseSend added in v2.0.162 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Context added in v2.0.162 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Header added in v2.0.162 

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

Header indicates an expected call of Header.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Recv added in v2.0.162 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) RecvMsg added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Send added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) SendMsg added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePersistentCachePeerClientMockRecorder) Trailer added in v2.0.162 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_AnnouncePersistentCachePeerServer added in v2.0.162 

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

MockScheduler_AnnouncePersistentCachePeerServer is a mock of Scheduler_AnnouncePersistentCachePeerServer interface.

func NewMockScheduler_AnnouncePersistentCachePeerServer added in v2.0.162 

func NewMockScheduler_AnnouncePersistentCachePeerServer(ctrl *gomock.Controller) *MockScheduler_AnnouncePersistentCachePeerServer

NewMockScheduler_AnnouncePersistentCachePeerServer creates a new mock instance.

func (*MockScheduler_AnnouncePersistentCachePeerServer) Context added in v2.0.162 

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

Context mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) EXPECT added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerServer) EXPECT() *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder

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

func (*MockScheduler_AnnouncePersistentCachePeerServer) Recv added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerServer) Recv() (*scheduler.AnnouncePersistentCachePeerRequest, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) RecvMsg added in v2.0.162 

func (m_2 *MockScheduler_AnnouncePersistentCachePeerServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) Send added in v2.0.162 

func (m *MockScheduler_AnnouncePersistentCachePeerServer) Send(arg0 *scheduler.AnnouncePersistentCachePeerResponse) error

Send mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) SendHeader added in v2.0.162 

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

SendHeader mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) SendMsg added in v2.0.162 

func (m_2 *MockScheduler_AnnouncePersistentCachePeerServer) SendMsg(m any) error

SendMsg mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) SetHeader added in v2.0.162 

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

SetHeader mocks base method.

func (*MockScheduler_AnnouncePersistentCachePeerServer) SetTrailer added in v2.0.162 

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

SetTrailer mocks base method.

type MockScheduler_AnnouncePersistentCachePeerServerMockRecorder added in v2.0.162 

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

MockScheduler_AnnouncePersistentCachePeerServerMockRecorder is the mock recorder for MockScheduler_AnnouncePersistentCachePeerServer.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) Context added in v2.0.162 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) Recv added in v2.0.162 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) RecvMsg added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) RecvMsg(m any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) Send added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SendHeader added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SendHeader(arg0 any) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SendMsg added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SendMsg(m any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SetHeader added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SetHeader(arg0 any) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SetTrailer added in v2.0.162 

func (mr *MockScheduler_AnnouncePersistentCachePeerServerMockRecorder) SetTrailer(arg0 any) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafeSchedulerServer 

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

MockUnsafeSchedulerServer is a mock of UnsafeSchedulerServer interface.

func NewMockUnsafeSchedulerServer 

func NewMockUnsafeSchedulerServer(ctrl *gomock.Controller) *MockUnsafeSchedulerServer

NewMockUnsafeSchedulerServer creates a new mock instance.

func (*MockUnsafeSchedulerServer) EXPECT 

func (m *MockUnsafeSchedulerServer) EXPECT() *MockUnsafeSchedulerServerMockRecorder

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

type MockUnsafeSchedulerServerMockRecorder 

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

MockUnsafeSchedulerServerMockRecorder is the mock recorder for MockUnsafeSchedulerServer.

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.