mocks

package
v2.1.92 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2025 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) 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) AnnouncePersistentPeer added in v2.1.86 

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

AnnouncePersistentPeer 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) 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) DeletePersistentPeer added in v2.1.86 

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

DeletePersistentPeer mocks base method.

func (*MockSchedulerClient) DeletePersistentTask added in v2.1.86 

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

DeletePersistentTask 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 *scheduler.ListHostsRequest, opts ...grpc.CallOption) (*scheduler.ListHostsResponse, error)

ListHosts mocks base method.

func (*MockSchedulerClient) PreheatFile added in v2.1.74 

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

PreheatFile mocks base method.

func (*MockSchedulerClient) PreheatImage added in v2.1.52 

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

PreheatImage mocks base method.

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) StatFile added in v2.1.74 

func (m *MockSchedulerClient) StatFile(ctx context.Context, in *scheduler.StatFileRequest, opts ...grpc.CallOption) (*scheduler.StatFileResponse, error)

StatFile mocks base method.

func (*MockSchedulerClient) StatImage added in v2.1.52 

func (m *MockSchedulerClient) StatImage(ctx context.Context, in *scheduler.StatImageRequest, opts ...grpc.CallOption) (*scheduler.StatImageResponse, error)

StatImage 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) StatPersistentPeer added in v2.1.86 

func (m *MockSchedulerClient) StatPersistentPeer(ctx context.Context, in *scheduler.StatPersistentPeerRequest, opts ...grpc.CallOption) (*common.PersistentPeer, error)

StatPersistentPeer mocks base method.

func (*MockSchedulerClient) StatPersistentTask added in v2.1.86 

func (m *MockSchedulerClient) StatPersistentTask(ctx context.Context, in *scheduler.StatPersistentTaskRequest, opts ...grpc.CallOption) (*common.PersistentTask, error)

StatPersistentTask 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.

func (*MockSchedulerClient) UploadPersistentTaskFailed added in v2.1.86 

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

UploadPersistentTaskFailed mocks base method.

func (*MockSchedulerClient) UploadPersistentTaskFinished added in v2.1.86 

func (m *MockSchedulerClient) UploadPersistentTaskFinished(ctx context.Context, in *scheduler.UploadPersistentTaskFinishedRequest, opts ...grpc.CallOption) (*common.PersistentTask, error)

UploadPersistentTaskFinished mocks base method.

func (*MockSchedulerClient) UploadPersistentTaskStarted added in v2.1.86 

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

UploadPersistentTaskStarted 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) 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) AnnouncePersistentPeer added in v2.1.86 

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

AnnouncePersistentPeer indicates an expected call of AnnouncePersistentPeer.

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) 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) DeletePersistentPeer added in v2.1.86 

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

DeletePersistentPeer indicates an expected call of DeletePersistentPeer.

func (*MockSchedulerClientMockRecorder) DeletePersistentTask added in v2.1.86 

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

DeletePersistentTask indicates an expected call of DeletePersistentTask.

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) PreheatFile added in v2.1.74 

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

PreheatFile indicates an expected call of PreheatFile.

func (*MockSchedulerClientMockRecorder) PreheatImage added in v2.1.52 

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

PreheatImage indicates an expected call of PreheatImage.

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) StatFile added in v2.1.74 

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

StatFile indicates an expected call of StatFile.

func (*MockSchedulerClientMockRecorder) StatImage added in v2.1.52 

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

StatImage indicates an expected call of StatImage.

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) StatPersistentPeer added in v2.1.86 

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

StatPersistentPeer indicates an expected call of StatPersistentPeer.

func (*MockSchedulerClientMockRecorder) StatPersistentTask added in v2.1.86 

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

StatPersistentTask indicates an expected call of StatPersistentTask.

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.

func (*MockSchedulerClientMockRecorder) UploadPersistentTaskFailed added in v2.1.86 

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

UploadPersistentTaskFailed indicates an expected call of UploadPersistentTaskFailed.

func (*MockSchedulerClientMockRecorder) UploadPersistentTaskFinished added in v2.1.86 

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

UploadPersistentTaskFinished indicates an expected call of UploadPersistentTaskFinished.

func (*MockSchedulerClientMockRecorder) UploadPersistentTaskStarted added in v2.1.86 

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

UploadPersistentTaskStarted indicates an expected call of UploadPersistentTaskStarted.

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) AnnouncePersistentCachePeer added in v2.0.162 

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

AnnouncePersistentCachePeer mocks base method.

func (*MockSchedulerServer) AnnouncePersistentPeer added in v2.1.86 

func (m *MockSchedulerServer) AnnouncePersistentPeer(arg0 scheduler.Scheduler_AnnouncePersistentPeerServer) error

AnnouncePersistentPeer 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) 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) DeletePersistentPeer added in v2.1.86 

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

DeletePersistentPeer mocks base method.

func (*MockSchedulerServer) DeletePersistentTask added in v2.1.86 

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

DeletePersistentTask 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 *scheduler.ListHostsRequest) (*scheduler.ListHostsResponse, error)

ListHosts mocks base method.

func (*MockSchedulerServer) PreheatFile added in v2.1.74 

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

PreheatFile mocks base method.

func (*MockSchedulerServer) PreheatImage added in v2.1.52 

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

PreheatImage mocks base method.

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) StatFile added in v2.1.74 

func (m *MockSchedulerServer) StatFile(arg0 context.Context, arg1 *scheduler.StatFileRequest) (*scheduler.StatFileResponse, error)

StatFile mocks base method.

func (*MockSchedulerServer) StatImage added in v2.1.52 

func (m *MockSchedulerServer) StatImage(arg0 context.Context, arg1 *scheduler.StatImageRequest) (*scheduler.StatImageResponse, error)

StatImage 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) StatPersistentPeer added in v2.1.86 

func (m *MockSchedulerServer) StatPersistentPeer(arg0 context.Context, arg1 *scheduler.StatPersistentPeerRequest) (*common.PersistentPeer, error)

StatPersistentPeer mocks base method.

func (*MockSchedulerServer) StatPersistentTask added in v2.1.86 

func (m *MockSchedulerServer) StatPersistentTask(arg0 context.Context, arg1 *scheduler.StatPersistentTaskRequest) (*common.PersistentTask, error)

StatPersistentTask 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.

func (*MockSchedulerServer) UploadPersistentTaskFailed added in v2.1.86 

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

UploadPersistentTaskFailed mocks base method.

func (*MockSchedulerServer) UploadPersistentTaskFinished added in v2.1.86 

func (m *MockSchedulerServer) UploadPersistentTaskFinished(arg0 context.Context, arg1 *scheduler.UploadPersistentTaskFinishedRequest) (*common.PersistentTask, error)

UploadPersistentTaskFinished mocks base method.

func (*MockSchedulerServer) UploadPersistentTaskStarted added in v2.1.86 

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

UploadPersistentTaskStarted 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) AnnouncePersistentCachePeer added in v2.0.162 

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

AnnouncePersistentCachePeer indicates an expected call of AnnouncePersistentCachePeer.

func (*MockSchedulerServerMockRecorder) AnnouncePersistentPeer added in v2.1.86 

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

AnnouncePersistentPeer indicates an expected call of AnnouncePersistentPeer.

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) 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) DeletePersistentPeer added in v2.1.86 

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

DeletePersistentPeer indicates an expected call of DeletePersistentPeer.

func (*MockSchedulerServerMockRecorder) DeletePersistentTask added in v2.1.86 

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

DeletePersistentTask indicates an expected call of DeletePersistentTask.

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) PreheatFile added in v2.1.74 

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

PreheatFile indicates an expected call of PreheatFile.

func (*MockSchedulerServerMockRecorder) PreheatImage added in v2.1.52 

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

PreheatImage indicates an expected call of PreheatImage.

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) StatFile added in v2.1.74 

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

StatFile indicates an expected call of StatFile.

func (*MockSchedulerServerMockRecorder) StatImage added in v2.1.52 

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

StatImage indicates an expected call of StatImage.

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) StatPersistentPeer added in v2.1.86 

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

StatPersistentPeer indicates an expected call of StatPersistentPeer.

func (*MockSchedulerServerMockRecorder) StatPersistentTask added in v2.1.86 

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

StatPersistentTask indicates an expected call of StatPersistentTask.

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.

func (*MockSchedulerServerMockRecorder) UploadPersistentTaskFailed added in v2.1.86 

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

UploadPersistentTaskFailed indicates an expected call of UploadPersistentTaskFailed.

func (*MockSchedulerServerMockRecorder) UploadPersistentTaskFinished added in v2.1.86 

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

UploadPersistentTaskFinished indicates an expected call of UploadPersistentTaskFinished.

func (*MockSchedulerServerMockRecorder) UploadPersistentTaskStarted added in v2.1.86 

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

UploadPersistentTaskStarted indicates an expected call of UploadPersistentTaskStarted.

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_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 MockScheduler_AnnouncePersistentPeerClient added in v2.1.86 

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

MockScheduler_AnnouncePersistentPeerClient is a mock of Scheduler_AnnouncePersistentPeerClient interface.

func NewMockScheduler_AnnouncePersistentPeerClient added in v2.1.86 

func NewMockScheduler_AnnouncePersistentPeerClient(ctrl *gomock.Controller) *MockScheduler_AnnouncePersistentPeerClient

NewMockScheduler_AnnouncePersistentPeerClient creates a new mock instance.

func (*MockScheduler_AnnouncePersistentPeerClient) CloseSend added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) Context added in v2.1.86 

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

Context mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) EXPECT added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerClient) EXPECT() *MockScheduler_AnnouncePersistentPeerClientMockRecorder

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

func (*MockScheduler_AnnouncePersistentPeerClient) Header added in v2.1.86 

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

Header mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) Recv added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerClient) Recv() (*scheduler.AnnouncePersistentPeerResponse, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) RecvMsg added in v2.1.86 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) Send added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerClient) Send(arg0 *scheduler.AnnouncePersistentPeerRequest) error

Send mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) SendMsg added in v2.1.86 

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

SendMsg mocks base method.

func (*MockScheduler_AnnouncePersistentPeerClient) Trailer added in v2.1.86 

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

Trailer mocks base method.

type MockScheduler_AnnouncePersistentPeerClientMockRecorder added in v2.1.86 

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

MockScheduler_AnnouncePersistentPeerClientMockRecorder is the mock recorder for MockScheduler_AnnouncePersistentPeerClient.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) CloseSend added in v2.1.86 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) Context added in v2.1.86 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) Header added in v2.1.86 

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

Header indicates an expected call of Header.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) Recv added in v2.1.86 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) RecvMsg added in v2.1.86 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) Send added in v2.1.86 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) SendMsg added in v2.1.86 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePersistentPeerClientMockRecorder) Trailer added in v2.1.86 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_AnnouncePersistentPeerServer added in v2.1.86 

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

MockScheduler_AnnouncePersistentPeerServer is a mock of Scheduler_AnnouncePersistentPeerServer interface.

func NewMockScheduler_AnnouncePersistentPeerServer added in v2.1.86 

func NewMockScheduler_AnnouncePersistentPeerServer(ctrl *gomock.Controller) *MockScheduler_AnnouncePersistentPeerServer

NewMockScheduler_AnnouncePersistentPeerServer creates a new mock instance.

func (*MockScheduler_AnnouncePersistentPeerServer) Context added in v2.1.86 

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

Context mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) EXPECT added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerServer) EXPECT() *MockScheduler_AnnouncePersistentPeerServerMockRecorder

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

func (*MockScheduler_AnnouncePersistentPeerServer) Recv added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerServer) Recv() (*scheduler.AnnouncePersistentPeerRequest, error)

Recv mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) RecvMsg added in v2.1.86 

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

RecvMsg mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) Send added in v2.1.86 

func (m *MockScheduler_AnnouncePersistentPeerServer) Send(arg0 *scheduler.AnnouncePersistentPeerResponse) error

Send mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) SendHeader added in v2.1.86 

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

SendHeader mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) SendMsg added in v2.1.86 

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

SendMsg mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) SetHeader added in v2.1.86 

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

SetHeader mocks base method.

func (*MockScheduler_AnnouncePersistentPeerServer) SetTrailer added in v2.1.86 

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

SetTrailer mocks base method.

type MockScheduler_AnnouncePersistentPeerServerMockRecorder added in v2.1.86 

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

MockScheduler_AnnouncePersistentPeerServerMockRecorder is the mock recorder for MockScheduler_AnnouncePersistentPeerServer.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) Context added in v2.1.86 

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

Context indicates an expected call of Context.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) Recv added in v2.1.86 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) RecvMsg added in v2.1.86 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) Send added in v2.1.86 

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

Send indicates an expected call of Send.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) SendHeader added in v2.1.86 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) SendMsg added in v2.1.86 

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

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) SetHeader added in v2.1.86 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_AnnouncePersistentPeerServerMockRecorder) SetTrailer added in v2.1.86 

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