mocks

package
v2.0.156 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 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) AnnounceCachePeer added in v2.0.121 

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

AnnounceCachePeer mocks base method.

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) AnnouncePeers added in v2.0.133 

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

AnnouncePeers mocks base method.

func (*MockSchedulerClient) DeleteCachePeer added in v2.0.121 

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

DeleteCachePeer mocks base method.

func (*MockSchedulerClient) DeleteCacheTask added in v2.0.121 

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

DeleteCacheTask 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) 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) StatCachePeer added in v2.0.121 

func (m *MockSchedulerClient) StatCachePeer(ctx context.Context, in *scheduler.StatCachePeerRequest, opts ...grpc.CallOption) (*common.CachePeer, error)

StatCachePeer mocks base method.

func (*MockSchedulerClient) StatCacheTask added in v2.0.121 

func (m *MockSchedulerClient) StatCacheTask(ctx context.Context, in *scheduler.StatCacheTaskRequest, opts ...grpc.CallOption) (*common.CacheTask, error)

StatCacheTask 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) StatTask 

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

StatTask mocks base method.

func (*MockSchedulerClient) SyncProbes 

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

SyncProbes mocks base method.

func (*MockSchedulerClient) UploadCacheTaskFailed added in v2.0.133 

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

UploadCacheTaskFailed mocks base method.

func (*MockSchedulerClient) UploadCacheTaskFinished added in v2.0.133 

func (m *MockSchedulerClient) UploadCacheTaskFinished(ctx context.Context, in *scheduler.UploadCacheTaskFinishedRequest, opts ...grpc.CallOption) (*common.CacheTask, error)

UploadCacheTaskFinished mocks base method.

func (*MockSchedulerClient) UploadCacheTaskStarted added in v2.0.133 

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

UploadCacheTaskStarted mocks base method.

type MockSchedulerClientMockRecorder 

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

MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.

func (*MockSchedulerClientMockRecorder) AnnounceCachePeer added in v2.0.121 

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

AnnounceCachePeer indicates an expected call of AnnounceCachePeer.

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) AnnouncePeers added in v2.0.133 

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

AnnouncePeers indicates an expected call of AnnouncePeers.

func (*MockSchedulerClientMockRecorder) DeleteCachePeer added in v2.0.121 

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

DeleteCachePeer indicates an expected call of DeleteCachePeer.

func (*MockSchedulerClientMockRecorder) DeleteCacheTask added in v2.0.121 

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

DeleteCacheTask indicates an expected call of DeleteCacheTask.

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) 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) StatCachePeer added in v2.0.121 

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

StatCachePeer indicates an expected call of StatCachePeer.

func (*MockSchedulerClientMockRecorder) StatCacheTask added in v2.0.121 

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

StatCacheTask indicates an expected call of StatCacheTask.

func (*MockSchedulerClientMockRecorder) StatPeer 

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

StatPeer indicates an expected call of StatPeer.

func (*MockSchedulerClientMockRecorder) StatTask 

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

StatTask indicates an expected call of StatTask.

func (*MockSchedulerClientMockRecorder) SyncProbes 

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

SyncProbes indicates an expected call of SyncProbes.

func (*MockSchedulerClientMockRecorder) UploadCacheTaskFailed added in v2.0.133 

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

UploadCacheTaskFailed indicates an expected call of UploadCacheTaskFailed.

func (*MockSchedulerClientMockRecorder) UploadCacheTaskFinished added in v2.0.133 

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

UploadCacheTaskFinished indicates an expected call of UploadCacheTaskFinished.

func (*MockSchedulerClientMockRecorder) UploadCacheTaskStarted added in v2.0.133 

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

UploadCacheTaskStarted indicates an expected call of UploadCacheTaskStarted.

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) AnnounceCachePeer added in v2.0.121 

func (m *MockSchedulerServer) AnnounceCachePeer(arg0 scheduler.Scheduler_AnnounceCachePeerServer) error

AnnounceCachePeer mocks base method.

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) AnnouncePeers added in v2.0.133 

func (m *MockSchedulerServer) AnnouncePeers(arg0 scheduler.Scheduler_AnnouncePeersServer) error

AnnouncePeers mocks base method.

func (*MockSchedulerServer) DeleteCachePeer added in v2.0.121 

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

DeleteCachePeer mocks base method.

func (*MockSchedulerServer) DeleteCacheTask added in v2.0.121 

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

DeleteCacheTask 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) 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) StatCachePeer added in v2.0.121 

func (m *MockSchedulerServer) StatCachePeer(arg0 context.Context, arg1 *scheduler.StatCachePeerRequest) (*common.CachePeer, error)

StatCachePeer mocks base method.

func (*MockSchedulerServer) StatCacheTask added in v2.0.121 

func (m *MockSchedulerServer) StatCacheTask(arg0 context.Context, arg1 *scheduler.StatCacheTaskRequest) (*common.CacheTask, error)

StatCacheTask 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) StatTask 

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

StatTask mocks base method.

func (*MockSchedulerServer) SyncProbes 

func (m *MockSchedulerServer) SyncProbes(arg0 scheduler.Scheduler_SyncProbesServer) error

SyncProbes mocks base method.

func (*MockSchedulerServer) UploadCacheTaskFailed added in v2.0.133 

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

UploadCacheTaskFailed mocks base method.

func (*MockSchedulerServer) UploadCacheTaskFinished added in v2.0.133 

func (m *MockSchedulerServer) UploadCacheTaskFinished(arg0 context.Context, arg1 *scheduler.UploadCacheTaskFinishedRequest) (*common.CacheTask, error)

UploadCacheTaskFinished mocks base method.

func (*MockSchedulerServer) UploadCacheTaskStarted added in v2.0.133 

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

UploadCacheTaskStarted mocks base method.

type MockSchedulerServerMockRecorder 

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

MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.

func (*MockSchedulerServerMockRecorder) AnnounceCachePeer added in v2.0.121 

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

AnnounceCachePeer indicates an expected call of AnnounceCachePeer.

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) AnnouncePeers added in v2.0.133 

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

AnnouncePeers indicates an expected call of AnnouncePeers.

func (*MockSchedulerServerMockRecorder) DeleteCachePeer added in v2.0.121 

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

DeleteCachePeer indicates an expected call of DeleteCachePeer.

func (*MockSchedulerServerMockRecorder) DeleteCacheTask added in v2.0.121 

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

DeleteCacheTask indicates an expected call of DeleteCacheTask.

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) DeleteTask added in v2.0.120 

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

DeleteTask indicates an expected call of DeleteTask.

func (*MockSchedulerServerMockRecorder) StatCachePeer added in v2.0.121 

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

StatCachePeer indicates an expected call of StatCachePeer.

func (*MockSchedulerServerMockRecorder) StatCacheTask added in v2.0.121 

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

StatCacheTask indicates an expected call of StatCacheTask.

func (*MockSchedulerServerMockRecorder) StatPeer 

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

StatPeer indicates an expected call of StatPeer.

func (*MockSchedulerServerMockRecorder) StatTask 

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

StatTask indicates an expected call of StatTask.

func (*MockSchedulerServerMockRecorder) SyncProbes 

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

SyncProbes indicates an expected call of SyncProbes.

func (*MockSchedulerServerMockRecorder) UploadCacheTaskFailed added in v2.0.133 

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

UploadCacheTaskFailed indicates an expected call of UploadCacheTaskFailed.

func (*MockSchedulerServerMockRecorder) UploadCacheTaskFinished added in v2.0.133 

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

UploadCacheTaskFinished indicates an expected call of UploadCacheTaskFinished.

func (*MockSchedulerServerMockRecorder) UploadCacheTaskStarted added in v2.0.133 

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

UploadCacheTaskStarted indicates an expected call of UploadCacheTaskStarted.

type MockScheduler_AnnounceCachePeerClient added in v2.0.121 

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

MockScheduler_AnnounceCachePeerClient is a mock of Scheduler_AnnounceCachePeerClient interface.

func NewMockScheduler_AnnounceCachePeerClient added in v2.0.121 

func NewMockScheduler_AnnounceCachePeerClient(ctrl *gomock.Controller) *MockScheduler_AnnounceCachePeerClient

NewMockScheduler_AnnounceCachePeerClient creates a new mock instance.

func (*MockScheduler_AnnounceCachePeerClient) CloseSend added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) Context added in v2.0.121 

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

Context mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) EXPECT added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerClient) EXPECT() *MockScheduler_AnnounceCachePeerClientMockRecorder

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

func (*MockScheduler_AnnounceCachePeerClient) Header added in v2.0.121 

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

Header mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) Recv added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerClient) Recv() (*scheduler.AnnounceCachePeerResponse, error)

Recv mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) RecvMsg added in v2.0.121 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) Send added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerClient) Send(arg0 *scheduler.AnnounceCachePeerRequest) error

Send mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) SendMsg added in v2.0.121 

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

SendMsg mocks base method.

func (*MockScheduler_AnnounceCachePeerClient) Trailer added in v2.0.121 

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

Trailer mocks base method.

type MockScheduler_AnnounceCachePeerClientMockRecorder added in v2.0.121 

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

MockScheduler_AnnounceCachePeerClientMockRecorder is the mock recorder for MockScheduler_AnnounceCachePeerClient.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) CloseSend added in v2.0.121 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) Context added in v2.0.121 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) Header added in v2.0.121 

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

Header indicates an expected call of Header.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) Recv added in v2.0.121 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) RecvMsg added in v2.0.121 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) Send added in v2.0.121 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) SendMsg added in v2.0.121 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnounceCachePeerClientMockRecorder) Trailer added in v2.0.121 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_AnnounceCachePeerServer added in v2.0.121 

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

MockScheduler_AnnounceCachePeerServer is a mock of Scheduler_AnnounceCachePeerServer interface.

func NewMockScheduler_AnnounceCachePeerServer added in v2.0.121 

func NewMockScheduler_AnnounceCachePeerServer(ctrl *gomock.Controller) *MockScheduler_AnnounceCachePeerServer

NewMockScheduler_AnnounceCachePeerServer creates a new mock instance.

func (*MockScheduler_AnnounceCachePeerServer) Context added in v2.0.121 

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

Context mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) EXPECT added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerServer) EXPECT() *MockScheduler_AnnounceCachePeerServerMockRecorder

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

func (*MockScheduler_AnnounceCachePeerServer) Recv added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerServer) Recv() (*scheduler.AnnounceCachePeerRequest, error)

Recv mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) RecvMsg added in v2.0.121 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) Send added in v2.0.121 

func (m *MockScheduler_AnnounceCachePeerServer) Send(arg0 *scheduler.AnnounceCachePeerResponse) error

Send mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) SendHeader added in v2.0.121 

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

SendHeader mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) SendMsg added in v2.0.121 

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

SendMsg mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) SetHeader added in v2.0.121 

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

SetHeader mocks base method.

func (*MockScheduler_AnnounceCachePeerServer) SetTrailer added in v2.0.121 

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

SetTrailer mocks base method.

type MockScheduler_AnnounceCachePeerServerMockRecorder added in v2.0.121 

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

MockScheduler_AnnounceCachePeerServerMockRecorder is the mock recorder for MockScheduler_AnnounceCachePeerServer.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) Context added in v2.0.121 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) Recv added in v2.0.121 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) RecvMsg added in v2.0.121 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) Send added in v2.0.121 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) SendHeader added in v2.0.121 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) SendMsg added in v2.0.121 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) SetHeader added in v2.0.121 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_AnnounceCachePeerServerMockRecorder) SetTrailer added in v2.0.121 

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

SetTrailer indicates an expected call of SetTrailer.

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_AnnouncePeersClient added in v2.0.133 

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

MockScheduler_AnnouncePeersClient is a mock of Scheduler_AnnouncePeersClient interface.

func NewMockScheduler_AnnouncePeersClient added in v2.0.133 

func NewMockScheduler_AnnouncePeersClient(ctrl *gomock.Controller) *MockScheduler_AnnouncePeersClient

NewMockScheduler_AnnouncePeersClient creates a new mock instance.

func (*MockScheduler_AnnouncePeersClient) CloseSend added in v2.0.133 

func (m *MockScheduler_AnnouncePeersClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_AnnouncePeersClient) Context added in v2.0.133 

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

Context mocks base method.

func (*MockScheduler_AnnouncePeersClient) EXPECT added in v2.0.133 

func (m *MockScheduler_AnnouncePeersClient) EXPECT() *MockScheduler_AnnouncePeersClientMockRecorder

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

func (*MockScheduler_AnnouncePeersClient) Header added in v2.0.133 

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

Header mocks base method.

func (*MockScheduler_AnnouncePeersClient) Recv added in v2.0.133 

func (m *MockScheduler_AnnouncePeersClient) Recv() (*emptypb.Empty, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePeersClient) RecvMsg added in v2.0.133 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePeersClient) Send added in v2.0.133 

func (m *MockScheduler_AnnouncePeersClient) Send(arg0 *scheduler.AnnouncePeersRequest) error

Send mocks base method.

func (*MockScheduler_AnnouncePeersClient) SendMsg added in v2.0.133 

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

SendMsg mocks base method.

func (*MockScheduler_AnnouncePeersClient) Trailer added in v2.0.133 

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

Trailer mocks base method.

type MockScheduler_AnnouncePeersClientMockRecorder added in v2.0.133 

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

MockScheduler_AnnouncePeersClientMockRecorder is the mock recorder for MockScheduler_AnnouncePeersClient.

func (*MockScheduler_AnnouncePeersClientMockRecorder) CloseSend added in v2.0.133 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_AnnouncePeersClientMockRecorder) Context added in v2.0.133 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePeersClientMockRecorder) Header added in v2.0.133 

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

Header indicates an expected call of Header.

func (*MockScheduler_AnnouncePeersClientMockRecorder) Recv added in v2.0.133 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePeersClientMockRecorder) RecvMsg added in v2.0.133 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePeersClientMockRecorder) Send added in v2.0.133 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePeersClientMockRecorder) SendMsg added in v2.0.133 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePeersClientMockRecorder) Trailer added in v2.0.133 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_AnnouncePeersServer added in v2.0.133 

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

MockScheduler_AnnouncePeersServer is a mock of Scheduler_AnnouncePeersServer interface.

func NewMockScheduler_AnnouncePeersServer added in v2.0.133 

func NewMockScheduler_AnnouncePeersServer(ctrl *gomock.Controller) *MockScheduler_AnnouncePeersServer

NewMockScheduler_AnnouncePeersServer creates a new mock instance.

func (*MockScheduler_AnnouncePeersServer) Context added in v2.0.133 

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

Context mocks base method.

func (*MockScheduler_AnnouncePeersServer) EXPECT added in v2.0.133 

func (m *MockScheduler_AnnouncePeersServer) EXPECT() *MockScheduler_AnnouncePeersServerMockRecorder

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

func (*MockScheduler_AnnouncePeersServer) Recv added in v2.0.133 

func (m *MockScheduler_AnnouncePeersServer) Recv() (*scheduler.AnnouncePeersRequest, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePeersServer) RecvMsg added in v2.0.133 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePeersServer) Send added in v2.0.133 

func (m *MockScheduler_AnnouncePeersServer) Send(arg0 *emptypb.Empty) error

Send mocks base method.

func (*MockScheduler_AnnouncePeersServer) SendHeader added in v2.0.133 

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

SendHeader mocks base method.

func (*MockScheduler_AnnouncePeersServer) SendMsg added in v2.0.133 

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

SendMsg mocks base method.

func (*MockScheduler_AnnouncePeersServer) SetHeader added in v2.0.133 

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

SetHeader mocks base method.

func (*MockScheduler_AnnouncePeersServer) SetTrailer added in v2.0.133 

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

SetTrailer mocks base method.

type MockScheduler_AnnouncePeersServerMockRecorder added in v2.0.133 

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

MockScheduler_AnnouncePeersServerMockRecorder is the mock recorder for MockScheduler_AnnouncePeersServer.

func (*MockScheduler_AnnouncePeersServerMockRecorder) Context added in v2.0.133 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePeersServerMockRecorder) Recv added in v2.0.133 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePeersServerMockRecorder) RecvMsg added in v2.0.133 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePeersServerMockRecorder) Send added in v2.0.133 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePeersServerMockRecorder) SendHeader added in v2.0.133 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_AnnouncePeersServerMockRecorder) SendMsg added in v2.0.133 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePeersServerMockRecorder) SetHeader added in v2.0.133 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_AnnouncePeersServerMockRecorder) SetTrailer added in v2.0.133 

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

SetTrailer indicates an expected call of SetTrailer.

type MockScheduler_SyncProbesClient 

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

MockScheduler_SyncProbesClient is a mock of Scheduler_SyncProbesClient interface.

func NewMockScheduler_SyncProbesClient 

func NewMockScheduler_SyncProbesClient(ctrl *gomock.Controller) *MockScheduler_SyncProbesClient

NewMockScheduler_SyncProbesClient creates a new mock instance.

func (*MockScheduler_SyncProbesClient) CloseSend 

func (m *MockScheduler_SyncProbesClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_SyncProbesClient) Context 

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

Context mocks base method.

func (*MockScheduler_SyncProbesClient) EXPECT 

func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder

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

func (*MockScheduler_SyncProbesClient) Header 

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

Header mocks base method.

func (*MockScheduler_SyncProbesClient) Recv 

func (m *MockScheduler_SyncProbesClient) Recv() (*scheduler.SyncProbesResponse, error)

Recv mocks base method.

func (*MockScheduler_SyncProbesClient) RecvMsg 

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

RecvMsg mocks base method.

func (*MockScheduler_SyncProbesClient) Send 

func (m *MockScheduler_SyncProbesClient) Send(arg0 *scheduler.SyncProbesRequest) error

Send mocks base method.

func (*MockScheduler_SyncProbesClient) SendMsg 

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

SendMsg mocks base method.

func (*MockScheduler_SyncProbesClient) Trailer 

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

Trailer mocks base method.

type MockScheduler_SyncProbesClientMockRecorder 

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

MockScheduler_SyncProbesClientMockRecorder is the mock recorder for MockScheduler_SyncProbesClient.

func (*MockScheduler_SyncProbesClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_SyncProbesClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_SyncProbesClientMockRecorder) Header 

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

Header indicates an expected call of Header.

func (*MockScheduler_SyncProbesClientMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_SyncProbesClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_SyncProbesClientMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockScheduler_SyncProbesClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_SyncProbesClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_SyncProbesServer 

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

MockScheduler_SyncProbesServer is a mock of Scheduler_SyncProbesServer interface.

func NewMockScheduler_SyncProbesServer 

func NewMockScheduler_SyncProbesServer(ctrl *gomock.Controller) *MockScheduler_SyncProbesServer

NewMockScheduler_SyncProbesServer creates a new mock instance.

func (*MockScheduler_SyncProbesServer) Context 

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

Context mocks base method.

func (*MockScheduler_SyncProbesServer) EXPECT 

func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder

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

func (*MockScheduler_SyncProbesServer) Recv 

func (m *MockScheduler_SyncProbesServer) Recv() (*scheduler.SyncProbesRequest, error)

Recv mocks base method.

func (*MockScheduler_SyncProbesServer) RecvMsg 

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

RecvMsg mocks base method.

func (*MockScheduler_SyncProbesServer) Send 

func (m *MockScheduler_SyncProbesServer) Send(arg0 *scheduler.SyncProbesResponse) error

Send mocks base method.

func (*MockScheduler_SyncProbesServer) SendHeader 

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

SendHeader mocks base method.

func (*MockScheduler_SyncProbesServer) SendMsg 

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

SendMsg mocks base method.

func (*MockScheduler_SyncProbesServer) SetHeader 

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

SetHeader mocks base method.

func (*MockScheduler_SyncProbesServer) SetTrailer 

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

SetTrailer mocks base method.

type MockScheduler_SyncProbesServerMockRecorder 

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

MockScheduler_SyncProbesServerMockRecorder is the mock recorder for MockScheduler_SyncProbesServer.

func (*MockScheduler_SyncProbesServerMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_SyncProbesServerMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_SyncProbesServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_SyncProbesServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockScheduler_SyncProbesServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_SyncProbesServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_SyncProbesServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_SyncProbesServerMockRecorder) SetTrailer 

func (mr *MockScheduler_SyncProbesServerMockRecorder) 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.