Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: ../scheduler_grpc.pb.go
Generated by this command:
mockgen -destination scheduler_mock.go -source ../scheduler_grpc.pb.go -package mocks
Package mocks is a generated GoMock package.
Index ¶
- type MockSchedulerClient
- func (m *MockSchedulerClient) AnnounceHost(ctx context.Context, in *scheduler.AnnounceHostRequest, ...) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) AnnounceTask(ctx context.Context, in *scheduler.AnnounceTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) EXPECT() *MockSchedulerClientMockRecorder
- func (m *MockSchedulerClient) LeaveHost(ctx context.Context, in *scheduler.LeaveHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) LeaveTask(ctx context.Context, in *scheduler.PeerTarget, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) RegisterPeerTask(ctx context.Context, in *scheduler.PeerTaskRequest, opts ...grpc.CallOption) (*scheduler.RegisterResult, error)
- func (m *MockSchedulerClient) ReportPeerResult(ctx context.Context, in *scheduler.PeerResult, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockSchedulerClient) ReportPieceResult(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_ReportPieceResultClient, error)
- func (m *MockSchedulerClient) StatTask(ctx context.Context, in *scheduler.StatTaskRequest, opts ...grpc.CallOption) (*scheduler.Task, error)
- func (m *MockSchedulerClient) SyncProbes(ctx context.Context, opts ...grpc.CallOption) (scheduler.Scheduler_SyncProbesClient, error)
- type MockSchedulerClientMockRecorder
- func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) AnnounceTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) LeaveHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) LeaveTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) RegisterPeerTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) ReportPeerResult(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) ReportPieceResult(ctx any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockSchedulerClientMockRecorder) SyncProbes(ctx any, opts ...any) *gomock.Call
- type MockSchedulerServer
- func (m *MockSchedulerServer) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) AnnounceTask(arg0 context.Context, arg1 *scheduler.AnnounceTaskRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) EXPECT() *MockSchedulerServerMockRecorder
- func (m *MockSchedulerServer) LeaveHost(arg0 context.Context, arg1 *scheduler.LeaveHostRequest) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) LeaveTask(arg0 context.Context, arg1 *scheduler.PeerTarget) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest) (*scheduler.RegisterResult, error)
- func (m *MockSchedulerServer) ReportPeerResult(arg0 context.Context, arg1 *scheduler.PeerResult) (*emptypb.Empty, error)
- func (m *MockSchedulerServer) ReportPieceResult(arg0 scheduler.Scheduler_ReportPieceResultServer) error
- func (m *MockSchedulerServer) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest) (*scheduler.Task, error)
- func (m *MockSchedulerServer) SyncProbes(arg0 scheduler.Scheduler_SyncProbesServer) error
- type MockSchedulerServerMockRecorder
- func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) AnnounceTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) LeaveHost(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) LeaveTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) RegisterPeerTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) ReportPeerResult(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) ReportPieceResult(arg0 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
- func (mr *MockSchedulerServerMockRecorder) SyncProbes(arg0 any) *gomock.Call
- type MockScheduler_ReportPieceResultClient
- func (m *MockScheduler_ReportPieceResultClient) CloseSend() error
- func (m *MockScheduler_ReportPieceResultClient) Context() context.Context
- func (m *MockScheduler_ReportPieceResultClient) EXPECT() *MockScheduler_ReportPieceResultClientMockRecorder
- func (m *MockScheduler_ReportPieceResultClient) Header() (metadata.MD, error)
- func (m *MockScheduler_ReportPieceResultClient) Recv() (*scheduler.PeerPacket, error)
- func (m_2 *MockScheduler_ReportPieceResultClient) RecvMsg(m any) error
- func (m *MockScheduler_ReportPieceResultClient) Send(arg0 *scheduler.PieceResult) error
- func (m_2 *MockScheduler_ReportPieceResultClient) SendMsg(m any) error
- func (m *MockScheduler_ReportPieceResultClient) Trailer() metadata.MD
- type MockScheduler_ReportPieceResultClientMockRecorder
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Header() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Trailer() *gomock.Call
- type MockScheduler_ReportPieceResultServer
- func (m *MockScheduler_ReportPieceResultServer) Context() context.Context
- func (m *MockScheduler_ReportPieceResultServer) EXPECT() *MockScheduler_ReportPieceResultServerMockRecorder
- func (m *MockScheduler_ReportPieceResultServer) Recv() (*scheduler.PieceResult, error)
- func (m_2 *MockScheduler_ReportPieceResultServer) RecvMsg(m any) error
- func (m *MockScheduler_ReportPieceResultServer) Send(arg0 *scheduler.PeerPacket) error
- func (m *MockScheduler_ReportPieceResultServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockScheduler_ReportPieceResultServer) SendMsg(m any) error
- func (m *MockScheduler_ReportPieceResultServer) SetHeader(arg0 metadata.MD) error
- func (m *MockScheduler_ReportPieceResultServer) SetTrailer(arg0 metadata.MD)
- type MockScheduler_ReportPieceResultServerMockRecorder
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockScheduler_SyncProbesClient
- func (m *MockScheduler_SyncProbesClient) CloseSend() error
- func (m *MockScheduler_SyncProbesClient) Context() context.Context
- func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder
- func (m *MockScheduler_SyncProbesClient) Header() (metadata.MD, error)
- func (m *MockScheduler_SyncProbesClient) Recv() (*scheduler.SyncProbesResponse, error)
- func (m_2 *MockScheduler_SyncProbesClient) RecvMsg(m any) error
- func (m *MockScheduler_SyncProbesClient) Send(arg0 *scheduler.SyncProbesRequest) error
- func (m_2 *MockScheduler_SyncProbesClient) SendMsg(m any) error
- func (m *MockScheduler_SyncProbesClient) Trailer() metadata.MD
- type MockScheduler_SyncProbesClientMockRecorder
- func (mr *MockScheduler_SyncProbesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Header() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesClientMockRecorder) Trailer() *gomock.Call
- type MockScheduler_SyncProbesServer
- func (m *MockScheduler_SyncProbesServer) Context() context.Context
- func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder
- func (m *MockScheduler_SyncProbesServer) Recv() (*scheduler.SyncProbesRequest, error)
- func (m_2 *MockScheduler_SyncProbesServer) RecvMsg(m any) error
- func (m *MockScheduler_SyncProbesServer) Send(arg0 *scheduler.SyncProbesResponse) error
- func (m *MockScheduler_SyncProbesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockScheduler_SyncProbesServer) SendMsg(m any) error
- func (m *MockScheduler_SyncProbesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockScheduler_SyncProbesServer) SetTrailer(arg0 metadata.MD)
- type MockScheduler_SyncProbesServerMockRecorder
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Context() *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Recv() *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockScheduler_SyncProbesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockUnsafeSchedulerServer
- type MockUnsafeSchedulerServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockSchedulerClient ¶
type MockSchedulerClient struct {
// contains filtered or unexported fields
}
MockSchedulerClient is a mock of SchedulerClient interface.
func NewMockSchedulerClient ¶
func NewMockSchedulerClient(ctrl *gomock.Controller) *MockSchedulerClient
NewMockSchedulerClient creates a new mock instance.
func (*MockSchedulerClient) AnnounceHost ¶
func (m *MockSchedulerClient) AnnounceHost(ctx context.Context, in *scheduler.AnnounceHostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
AnnounceHost mocks base method.
func (*MockSchedulerClient) 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 ¶
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 ¶
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 ¶
func (mr *MockSchedulerClientMockRecorder) AnnounceHost(ctx, in any, opts ...any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockSchedulerClientMockRecorder) AnnounceTask ¶
func (mr *MockSchedulerClientMockRecorder) AnnounceTask(ctx, in any, opts ...any) *gomock.Call
AnnounceTask indicates an expected call of AnnounceTask.
func (*MockSchedulerClientMockRecorder) LeaveHost ¶
func (mr *MockSchedulerClientMockRecorder) LeaveHost(ctx, in any, opts ...any) *gomock.Call
LeaveHost indicates an expected call of LeaveHost.
func (*MockSchedulerClientMockRecorder) LeaveTask ¶
func (mr *MockSchedulerClientMockRecorder) LeaveTask(ctx, in any, opts ...any) *gomock.Call
LeaveTask indicates an expected call of LeaveTask.
func (*MockSchedulerClientMockRecorder) RegisterPeerTask ¶
func (mr *MockSchedulerClientMockRecorder) RegisterPeerTask(ctx, in any, opts ...any) *gomock.Call
RegisterPeerTask indicates an expected call of RegisterPeerTask.
func (*MockSchedulerClientMockRecorder) ReportPeerResult ¶
func (mr *MockSchedulerClientMockRecorder) ReportPeerResult(ctx, in any, opts ...any) *gomock.Call
ReportPeerResult indicates an expected call of ReportPeerResult.
func (*MockSchedulerClientMockRecorder) ReportPieceResult ¶
func (mr *MockSchedulerClientMockRecorder) ReportPieceResult(ctx any, opts ...any) *gomock.Call
ReportPieceResult indicates an expected call of ReportPieceResult.
func (*MockSchedulerClientMockRecorder) StatTask ¶
func (mr *MockSchedulerClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockSchedulerClientMockRecorder) SyncProbes ¶
func (mr *MockSchedulerClientMockRecorder) SyncProbes(ctx any, opts ...any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.
type MockSchedulerServer ¶
type MockSchedulerServer struct {
// contains filtered or unexported fields
}
MockSchedulerServer is a mock of SchedulerServer interface.
func NewMockSchedulerServer ¶
func NewMockSchedulerServer(ctrl *gomock.Controller) *MockSchedulerServer
NewMockSchedulerServer creates a new mock instance.
func (*MockSchedulerServer) AnnounceHost ¶
func (m *MockSchedulerServer) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest) (*emptypb.Empty, error)
AnnounceHost mocks base method.
func (*MockSchedulerServer) 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 ¶
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 ¶
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 ¶
func (mr *MockSchedulerServerMockRecorder) AnnounceHost(arg0, arg1 any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockSchedulerServerMockRecorder) AnnounceTask ¶
func (mr *MockSchedulerServerMockRecorder) AnnounceTask(arg0, arg1 any) *gomock.Call
AnnounceTask indicates an expected call of AnnounceTask.
func (*MockSchedulerServerMockRecorder) LeaveHost ¶
func (mr *MockSchedulerServerMockRecorder) LeaveHost(arg0, arg1 any) *gomock.Call
LeaveHost indicates an expected call of LeaveHost.
func (*MockSchedulerServerMockRecorder) LeaveTask ¶
func (mr *MockSchedulerServerMockRecorder) LeaveTask(arg0, arg1 any) *gomock.Call
LeaveTask indicates an expected call of LeaveTask.
func (*MockSchedulerServerMockRecorder) RegisterPeerTask ¶
func (mr *MockSchedulerServerMockRecorder) RegisterPeerTask(arg0, arg1 any) *gomock.Call
RegisterPeerTask indicates an expected call of RegisterPeerTask.
func (*MockSchedulerServerMockRecorder) ReportPeerResult ¶
func (mr *MockSchedulerServerMockRecorder) ReportPeerResult(arg0, arg1 any) *gomock.Call
ReportPeerResult indicates an expected call of ReportPeerResult.
func (*MockSchedulerServerMockRecorder) ReportPieceResult ¶
func (mr *MockSchedulerServerMockRecorder) ReportPieceResult(arg0 any) *gomock.Call
ReportPieceResult indicates an expected call of ReportPieceResult.
func (*MockSchedulerServerMockRecorder) StatTask ¶
func (mr *MockSchedulerServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockSchedulerServerMockRecorder) SyncProbes ¶
func (mr *MockSchedulerServerMockRecorder) SyncProbes(arg0 any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.
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 any) 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 any) 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 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_ReportPieceResultClientMockRecorder) Send ¶
func (mr *MockScheduler_ReportPieceResultClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_ReportPieceResultClientMockRecorder) SendMsg ¶
func (mr *MockScheduler_ReportPieceResultClientMockRecorder) SendMsg(m any) *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 any) 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 any) 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 any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_ReportPieceResultServerMockRecorder) Send ¶
func (mr *MockScheduler_ReportPieceResultServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_ReportPieceResultServerMockRecorder) SendHeader ¶
func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockScheduler_ReportPieceResultServerMockRecorder) SendMsg ¶
func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_ReportPieceResultServerMockRecorder) SetHeader ¶
func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockScheduler_ReportPieceResultServerMockRecorder) SetTrailer ¶
func (mr *MockScheduler_ReportPieceResultServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockScheduler_SyncProbesClient ¶
type MockScheduler_SyncProbesClient struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesClient is a mock of Scheduler_SyncProbesClient interface.
func NewMockScheduler_SyncProbesClient ¶
func NewMockScheduler_SyncProbesClient(ctrl *gomock.Controller) *MockScheduler_SyncProbesClient
NewMockScheduler_SyncProbesClient creates a new mock instance.
func (*MockScheduler_SyncProbesClient) CloseSend ¶
func (m *MockScheduler_SyncProbesClient) CloseSend() error
CloseSend mocks base method.
func (*MockScheduler_SyncProbesClient) Context ¶
func (m *MockScheduler_SyncProbesClient) Context() context.Context
Context mocks base method.
func (*MockScheduler_SyncProbesClient) EXPECT ¶
func (m *MockScheduler_SyncProbesClient) EXPECT() *MockScheduler_SyncProbesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_SyncProbesClient) Header ¶
func (m *MockScheduler_SyncProbesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockScheduler_SyncProbesClient) Recv ¶
func (m *MockScheduler_SyncProbesClient) Recv() (*scheduler.SyncProbesResponse, error)
Recv mocks base method.
func (*MockScheduler_SyncProbesClient) RecvMsg ¶
func (m_2 *MockScheduler_SyncProbesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_SyncProbesClient) Send ¶
func (m *MockScheduler_SyncProbesClient) Send(arg0 *scheduler.SyncProbesRequest) error
Send mocks base method.
func (*MockScheduler_SyncProbesClient) SendMsg ¶
func (m_2 *MockScheduler_SyncProbesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_SyncProbesClient) Trailer ¶
func (m *MockScheduler_SyncProbesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockScheduler_SyncProbesClientMockRecorder ¶
type MockScheduler_SyncProbesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesClientMockRecorder is the mock recorder for MockScheduler_SyncProbesClient.
func (*MockScheduler_SyncProbesClientMockRecorder) CloseSend ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockScheduler_SyncProbesClientMockRecorder) Context ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_SyncProbesClientMockRecorder) Header ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockScheduler_SyncProbesClientMockRecorder) Recv ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_SyncProbesClientMockRecorder) RecvMsg ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_SyncProbesClientMockRecorder) Send ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_SyncProbesClientMockRecorder) SendMsg ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_SyncProbesClientMockRecorder) Trailer ¶
func (mr *MockScheduler_SyncProbesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockScheduler_SyncProbesServer ¶
type MockScheduler_SyncProbesServer struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesServer is a mock of Scheduler_SyncProbesServer interface.
func NewMockScheduler_SyncProbesServer ¶
func NewMockScheduler_SyncProbesServer(ctrl *gomock.Controller) *MockScheduler_SyncProbesServer
NewMockScheduler_SyncProbesServer creates a new mock instance.
func (*MockScheduler_SyncProbesServer) Context ¶
func (m *MockScheduler_SyncProbesServer) Context() context.Context
Context mocks base method.
func (*MockScheduler_SyncProbesServer) EXPECT ¶
func (m *MockScheduler_SyncProbesServer) EXPECT() *MockScheduler_SyncProbesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler_SyncProbesServer) Recv ¶
func (m *MockScheduler_SyncProbesServer) Recv() (*scheduler.SyncProbesRequest, error)
Recv mocks base method.
func (*MockScheduler_SyncProbesServer) RecvMsg ¶
func (m_2 *MockScheduler_SyncProbesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockScheduler_SyncProbesServer) Send ¶
func (m *MockScheduler_SyncProbesServer) Send(arg0 *scheduler.SyncProbesResponse) error
Send mocks base method.
func (*MockScheduler_SyncProbesServer) SendHeader ¶
func (m *MockScheduler_SyncProbesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockScheduler_SyncProbesServer) SendMsg ¶
func (m_2 *MockScheduler_SyncProbesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockScheduler_SyncProbesServer) SetHeader ¶
func (m *MockScheduler_SyncProbesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockScheduler_SyncProbesServer) SetTrailer ¶
func (m *MockScheduler_SyncProbesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockScheduler_SyncProbesServerMockRecorder ¶
type MockScheduler_SyncProbesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockScheduler_SyncProbesServerMockRecorder is the mock recorder for MockScheduler_SyncProbesServer.
func (*MockScheduler_SyncProbesServerMockRecorder) Context ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockScheduler_SyncProbesServerMockRecorder) Recv ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockScheduler_SyncProbesServerMockRecorder) RecvMsg ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockScheduler_SyncProbesServerMockRecorder) Send ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockScheduler_SyncProbesServerMockRecorder) SendHeader ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockScheduler_SyncProbesServerMockRecorder) SendMsg ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockScheduler_SyncProbesServerMockRecorder) SetHeader ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockScheduler_SyncProbesServerMockRecorder) SetTrailer ¶
func (mr *MockScheduler_SyncProbesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockUnsafeSchedulerServer ¶
type MockUnsafeSchedulerServer struct {
// contains filtered or unexported fields
}
MockUnsafeSchedulerServer is a mock of UnsafeSchedulerServer interface.
func NewMockUnsafeSchedulerServer ¶
func NewMockUnsafeSchedulerServer(ctrl *gomock.Controller) *MockUnsafeSchedulerServer
NewMockUnsafeSchedulerServer creates a new mock instance.
func (*MockUnsafeSchedulerServer) EXPECT ¶
func (m *MockUnsafeSchedulerServer) EXPECT() *MockUnsafeSchedulerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeSchedulerServerMockRecorder ¶
type MockUnsafeSchedulerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeSchedulerServerMockRecorder is the mock recorder for MockUnsafeSchedulerServer.