mocks

package
v1.9.9 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockSchedulerClient 

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

MockSchedulerClient is a mock of SchedulerClient interface.

func NewMockSchedulerClient 

func NewMockSchedulerClient(ctrl *gomock.Controller) *MockSchedulerClient

NewMockSchedulerClient creates a new mock instance.

func (*MockSchedulerClient) AnnounceHost added in v1.2.5 

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

AnnounceHost mocks base method.

func (*MockSchedulerClient) AnnounceTask 

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

AnnounceTask 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) LeaveHost added in v1.2.2 

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

LeaveHost mocks base method.

func (*MockSchedulerClient) LeaveTask 

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

LeaveTask mocks base method.

func (*MockSchedulerClient) RegisterPeerTask 

func (m *MockSchedulerClient) RegisterPeerTask(ctx context.Context, in *scheduler.PeerTaskRequest, opts ...grpc.CallOption) (*scheduler.RegisterResult, error)

RegisterPeerTask mocks base method.

func (*MockSchedulerClient) ReportPeerResult 

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

ReportPeerResult mocks base method.

func (*MockSchedulerClient) ReportPieceResult 

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

ReportPieceResult mocks base method.

func (*MockSchedulerClient) StatTask 

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

StatTask mocks base method.

func (*MockSchedulerClient) SyncProbes added in v1.4.8 

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

SyncProbes mocks base method.

type MockSchedulerClientMockRecorder 

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

MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.

func (*MockSchedulerClientMockRecorder) AnnounceHost added in v1.2.5 

func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in interface{}, opts ...interface{}) *gomock.Call

AnnounceHost indicates an expected call of AnnounceHost.

func (*MockSchedulerClientMockRecorder) AnnounceTask 

func (mr *MockSchedulerClientMockRecorder) AnnounceTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

AnnounceTask indicates an expected call of AnnounceTask.

func (*MockSchedulerClientMockRecorder) LeaveHost added in v1.2.2 

func (mr *MockSchedulerClientMockRecorder) LeaveHost(ctx, in interface{}, opts ...interface{}) *gomock.Call

LeaveHost indicates an expected call of LeaveHost.

func (*MockSchedulerClientMockRecorder) LeaveTask 

func (mr *MockSchedulerClientMockRecorder) LeaveTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

LeaveTask indicates an expected call of LeaveTask.

func (*MockSchedulerClientMockRecorder) RegisterPeerTask 

func (mr *MockSchedulerClientMockRecorder) RegisterPeerTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

RegisterPeerTask indicates an expected call of RegisterPeerTask.

func (*MockSchedulerClientMockRecorder) ReportPeerResult 

func (mr *MockSchedulerClientMockRecorder) ReportPeerResult(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReportPeerResult indicates an expected call of ReportPeerResult.

func (*MockSchedulerClientMockRecorder) ReportPieceResult 

func (mr *MockSchedulerClientMockRecorder) ReportPieceResult(ctx interface{}, opts ...interface{}) *gomock.Call

ReportPieceResult indicates an expected call of ReportPieceResult.

func (*MockSchedulerClientMockRecorder) StatTask 

func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in interface{}, opts ...interface{}) *gomock.Call

StatTask indicates an expected call of StatTask.

func (*MockSchedulerClientMockRecorder) SyncProbes added in v1.4.8 

func (mr *MockSchedulerClientMockRecorder) SyncProbes(ctx interface{}, opts ...interface{}) *gomock.Call

SyncProbes indicates an expected call of SyncProbes.

type MockSchedulerServer 

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

MockSchedulerServer is a mock of SchedulerServer interface.

func NewMockSchedulerServer 

func NewMockSchedulerServer(ctrl *gomock.Controller) *MockSchedulerServer

NewMockSchedulerServer creates a new mock instance.

func (*MockSchedulerServer) AnnounceHost added in v1.2.5 

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

AnnounceHost mocks base method.

func (*MockSchedulerServer) AnnounceTask 

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

AnnounceTask 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) LeaveHost added in v1.2.2 

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

LeaveHost mocks base method.

func (*MockSchedulerServer) LeaveTask 

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

LeaveTask mocks base method.

func (*MockSchedulerServer) RegisterPeerTask 

func (m *MockSchedulerServer) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest) (*scheduler.RegisterResult, error)

RegisterPeerTask mocks base method.

func (*MockSchedulerServer) ReportPeerResult 

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

ReportPeerResult mocks base method.

func (*MockSchedulerServer) ReportPieceResult 

func (m *MockSchedulerServer) ReportPieceResult(arg0 scheduler.Scheduler_ReportPieceResultServer) error

ReportPieceResult mocks base method.

func (*MockSchedulerServer) StatTask 

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

StatTask mocks base method.

func (*MockSchedulerServer) SyncProbes added in v1.4.8 

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

SyncProbes mocks base method.

type MockSchedulerServerMockRecorder 

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

MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.

func (*MockSchedulerServerMockRecorder) AnnounceHost added in v1.2.5 

func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 interface{}) *gomock.Call

AnnounceHost indicates an expected call of AnnounceHost.

func (*MockSchedulerServerMockRecorder) AnnounceTask 

func (mr *MockSchedulerServerMockRecorder) AnnounceTask(arg0, arg1 interface{}) *gomock.Call

AnnounceTask indicates an expected call of AnnounceTask.

func (*MockSchedulerServerMockRecorder) LeaveHost added in v1.2.2 

func (mr *MockSchedulerServerMockRecorder) LeaveHost(arg0, arg1 interface{}) *gomock.Call

LeaveHost indicates an expected call of LeaveHost.

func (*MockSchedulerServerMockRecorder) LeaveTask 

func (mr *MockSchedulerServerMockRecorder) LeaveTask(arg0, arg1 interface{}) *gomock.Call

LeaveTask indicates an expected call of LeaveTask.

func (*MockSchedulerServerMockRecorder) RegisterPeerTask 

func (mr *MockSchedulerServerMockRecorder) RegisterPeerTask(arg0, arg1 interface{}) *gomock.Call

RegisterPeerTask indicates an expected call of RegisterPeerTask.

func (*MockSchedulerServerMockRecorder) ReportPeerResult 

func (mr *MockSchedulerServerMockRecorder) ReportPeerResult(arg0, arg1 interface{}) *gomock.Call

ReportPeerResult indicates an expected call of ReportPeerResult.

func (*MockSchedulerServerMockRecorder) ReportPieceResult 

func (mr *MockSchedulerServerMockRecorder) ReportPieceResult(arg0 interface{}) *gomock.Call

ReportPieceResult indicates an expected call of ReportPieceResult.

func (*MockSchedulerServerMockRecorder) StatTask 

func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 interface{}) *gomock.Call

StatTask indicates an expected call of StatTask.

func (*MockSchedulerServerMockRecorder) SyncProbes added in v1.4.8 

func (mr *MockSchedulerServerMockRecorder) SyncProbes(arg0 interface{}) *gomock.Call

SyncProbes indicates an expected call of SyncProbes.

type MockScheduler_ReportPieceResultClient 

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

MockScheduler_ReportPieceResultClient is a mock of Scheduler_ReportPieceResultClient interface.

func NewMockScheduler_ReportPieceResultClient 

func NewMockScheduler_ReportPieceResultClient(ctrl *gomock.Controller) *MockScheduler_ReportPieceResultClient

NewMockScheduler_ReportPieceResultClient creates a new mock instance.

func (*MockScheduler_ReportPieceResultClient) CloseSend 

func (m *MockScheduler_ReportPieceResultClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_ReportPieceResultClient) Context 

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

Context mocks base method.

func (*MockScheduler_ReportPieceResultClient) EXPECT 

func (m *MockScheduler_ReportPieceResultClient) EXPECT() *MockScheduler_ReportPieceResultClientMockRecorder

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

func (*MockScheduler_ReportPieceResultClient) Header 

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

Header mocks base method.

func (*MockScheduler_ReportPieceResultClient) Recv 

func (m *MockScheduler_ReportPieceResultClient) Recv() (*scheduler.PeerPacket, error)

Recv mocks base method.

func (*MockScheduler_ReportPieceResultClient) RecvMsg 

func (m_2 *MockScheduler_ReportPieceResultClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_ReportPieceResultClient) Send 

func (m *MockScheduler_ReportPieceResultClient) Send(arg0 *scheduler.PieceResult) error

Send mocks base method.

func (*MockScheduler_ReportPieceResultClient) SendMsg 

func (m_2 *MockScheduler_ReportPieceResultClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_ReportPieceResultClient) Trailer 

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

Trailer mocks base method.

type MockScheduler_ReportPieceResultClientMockRecorder 

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

MockScheduler_ReportPieceResultClientMockRecorder is the mock recorder for MockScheduler_ReportPieceResultClient.

func (*MockScheduler_ReportPieceResultClientMockRecorder) CloseSend 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_ReportPieceResultClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_ReportPieceResultClientMockRecorder) Header 

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

Header indicates an expected call of Header.

func (*MockScheduler_ReportPieceResultClientMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_ReportPieceResultClientMockRecorder) RecvMsg 

func (mr *MockScheduler_ReportPieceResultClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_ReportPieceResultClientMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockScheduler_ReportPieceResultClientMockRecorder) SendMsg 

func (mr *MockScheduler_ReportPieceResultClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_ReportPieceResultClientMockRecorder) Trailer 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_ReportPieceResultServer 

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

MockScheduler_ReportPieceResultServer is a mock of Scheduler_ReportPieceResultServer interface.

func NewMockScheduler_ReportPieceResultServer 

func NewMockScheduler_ReportPieceResultServer(ctrl *gomock.Controller) *MockScheduler_ReportPieceResultServer

NewMockScheduler_ReportPieceResultServer creates a new mock instance.

func (*MockScheduler_ReportPieceResultServer) Context 

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

Context mocks base method.

func (*MockScheduler_ReportPieceResultServer) EXPECT 

func (m *MockScheduler_ReportPieceResultServer) EXPECT() *MockScheduler_ReportPieceResultServerMockRecorder

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

func (*MockScheduler_ReportPieceResultServer) Recv 

func (m *MockScheduler_ReportPieceResultServer) Recv() (*scheduler.PieceResult, error)

Recv mocks base method.

func (*MockScheduler_ReportPieceResultServer) RecvMsg 

func (m_2 *MockScheduler_ReportPieceResultServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_ReportPieceResultServer) Send 

func (m *MockScheduler_ReportPieceResultServer) Send(arg0 *scheduler.PeerPacket) error

Send mocks base method.

func (*MockScheduler_ReportPieceResultServer) SendHeader 

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

SendHeader mocks base method.

func (*MockScheduler_ReportPieceResultServer) SendMsg 

func (m_2 *MockScheduler_ReportPieceResultServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_ReportPieceResultServer) SetHeader 

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

SetHeader mocks base method.

func (*MockScheduler_ReportPieceResultServer) SetTrailer 

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

SetTrailer mocks base method.

type MockScheduler_ReportPieceResultServerMockRecorder 

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

MockScheduler_ReportPieceResultServerMockRecorder is the mock recorder for MockScheduler_ReportPieceResultServer.

func (*MockScheduler_ReportPieceResultServerMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockScheduler_ReportPieceResultServerMockRecorder) Recv 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_ReportPieceResultServerMockRecorder) RecvMsg 

func (mr *MockScheduler_ReportPieceResultServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_ReportPieceResultServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockScheduler_ReportPieceResultServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_ReportPieceResultServerMockRecorder) SendMsg 

func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_ReportPieceResultServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_ReportPieceResultServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockScheduler_SyncProbesClient added in v1.4.8 

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

MockScheduler_SyncProbesClient is a mock of Scheduler_SyncProbesClient interface.

func NewMockScheduler_SyncProbesClient added in v1.4.8 

func NewMockScheduler_SyncProbesClient(ctrl *gomock.Controller) *MockScheduler_SyncProbesClient

NewMockScheduler_SyncProbesClient creates a new mock instance.

func (*MockScheduler_SyncProbesClient) CloseSend added in v1.4.8 

func (m *MockScheduler_SyncProbesClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_SyncProbesClient) Context added in v1.4.8 

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

Context mocks base method.

func (*MockScheduler_SyncProbesClient) EXPECT added in v1.4.8 

func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder

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

func (*MockScheduler_SyncProbesClient) Header added in v1.4.8 

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

Header mocks base method.

func (*MockScheduler_SyncProbesClient) Recv added in v1.4.8 

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

Recv mocks base method.

func (*MockScheduler_SyncProbesClient) RecvMsg added in v1.4.8 

func (m_2 *MockScheduler_SyncProbesClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_SyncProbesClient) Send added in v1.4.8 

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

Send mocks base method.

func (*MockScheduler_SyncProbesClient) SendMsg added in v1.4.8 

func (m_2 *MockScheduler_SyncProbesClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_SyncProbesClient) Trailer added in v1.4.8 

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

Trailer mocks base method.

type MockScheduler_SyncProbesClientMockRecorder added in v1.4.8 

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

MockScheduler_SyncProbesClientMockRecorder is the mock recorder for MockScheduler_SyncProbesClient.

func (*MockScheduler_SyncProbesClientMockRecorder) CloseSend added in v1.4.8 

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

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_SyncProbesClientMockRecorder) Context added in v1.4.8 

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

Context indicates an expected call of Context.

func (*MockScheduler_SyncProbesClientMockRecorder) Header added in v1.4.8 

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

Header indicates an expected call of Header.

func (*MockScheduler_SyncProbesClientMockRecorder) Recv added in v1.4.8 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_SyncProbesClientMockRecorder) RecvMsg added in v1.4.8 

func (mr *MockScheduler_SyncProbesClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_SyncProbesClientMockRecorder) Send added in v1.4.8 

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

Send indicates an expected call of Send.

func (*MockScheduler_SyncProbesClientMockRecorder) SendMsg added in v1.4.8 

func (mr *MockScheduler_SyncProbesClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_SyncProbesClientMockRecorder) Trailer added in v1.4.8 

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

Trailer indicates an expected call of Trailer.

type MockScheduler_SyncProbesServer added in v1.4.8 

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

MockScheduler_SyncProbesServer is a mock of Scheduler_SyncProbesServer interface.

func NewMockScheduler_SyncProbesServer added in v1.4.8 

func NewMockScheduler_SyncProbesServer(ctrl *gomock.Controller) *MockScheduler_SyncProbesServer

NewMockScheduler_SyncProbesServer creates a new mock instance.

func (*MockScheduler_SyncProbesServer) Context added in v1.4.8 

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

Context mocks base method.

func (*MockScheduler_SyncProbesServer) EXPECT added in v1.4.8 

func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder

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

func (*MockScheduler_SyncProbesServer) Recv added in v1.4.8 

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

Recv mocks base method.

func (*MockScheduler_SyncProbesServer) RecvMsg added in v1.4.8 

func (m_2 *MockScheduler_SyncProbesServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_SyncProbesServer) Send added in v1.4.8 

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

Send mocks base method.

func (*MockScheduler_SyncProbesServer) SendHeader added in v1.4.8 

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

SendHeader mocks base method.

func (*MockScheduler_SyncProbesServer) SendMsg added in v1.4.8 

func (m_2 *MockScheduler_SyncProbesServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_SyncProbesServer) SetHeader added in v1.4.8 

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

SetHeader mocks base method.

func (*MockScheduler_SyncProbesServer) SetTrailer added in v1.4.8 

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

SetTrailer mocks base method.

type MockScheduler_SyncProbesServerMockRecorder added in v1.4.8 

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

MockScheduler_SyncProbesServerMockRecorder is the mock recorder for MockScheduler_SyncProbesServer.

func (*MockScheduler_SyncProbesServerMockRecorder) Context added in v1.4.8 

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

Context indicates an expected call of Context.

func (*MockScheduler_SyncProbesServerMockRecorder) Recv added in v1.4.8 

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

Recv indicates an expected call of Recv.

func (*MockScheduler_SyncProbesServerMockRecorder) RecvMsg added in v1.4.8 

func (mr *MockScheduler_SyncProbesServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_SyncProbesServerMockRecorder) Send added in v1.4.8 

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

Send indicates an expected call of Send.

func (*MockScheduler_SyncProbesServerMockRecorder) SendHeader added in v1.4.8 

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

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_SyncProbesServerMockRecorder) SendMsg added in v1.4.8 

func (mr *MockScheduler_SyncProbesServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_SyncProbesServerMockRecorder) SetHeader added in v1.4.8 

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

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_SyncProbesServerMockRecorder) SetTrailer added in v1.4.8 

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

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafeSchedulerServer added in v1.4.7 

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

MockUnsafeSchedulerServer is a mock of UnsafeSchedulerServer interface.

func NewMockUnsafeSchedulerServer added in v1.4.7 

func NewMockUnsafeSchedulerServer(ctrl *gomock.Controller) *MockUnsafeSchedulerServer

NewMockUnsafeSchedulerServer creates a new mock instance.

func (*MockUnsafeSchedulerServer) EXPECT added in v1.4.7 

func (m *MockUnsafeSchedulerServer) EXPECT() *MockUnsafeSchedulerServerMockRecorder

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

type MockUnsafeSchedulerServerMockRecorder added in v1.4.7 

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.