Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: client_v1.go
Generated by this command:
mockgen -destination mocks/client_v1_mock.go -source client_v1.go -package mocks
Package mocks is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: client_v2.go
Generated by this command:
mockgen -destination mocks/client_v2_mock.go -source client_v2.go -package mocks
Package mocks is a generated GoMock package.
Index ¶
- type MockV1
- func (m *MockV1) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest, ...) error
- func (m *MockV1) AnnounceTask(arg0 context.Context, arg1 *scheduler.AnnounceTaskRequest, ...) error
- func (m *MockV1) Close() error
- func (m *MockV1) EXPECT() *MockV1MockRecorder
- func (m *MockV1) LeaveHost(arg0 context.Context, arg1 *scheduler.LeaveHostRequest, ...) error
- func (m *MockV1) LeaveTask(arg0 context.Context, arg1 *scheduler.PeerTarget, arg2 ...grpc.CallOption) error
- func (m *MockV1) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (*scheduler.RegisterResult, error)
- func (m *MockV1) ReportPeerResult(arg0 context.Context, arg1 *scheduler.PeerResult, arg2 ...grpc.CallOption) error
- func (m *MockV1) ReportPieceResult(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_ReportPieceResultClient, error)
- func (m *MockV1) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*scheduler.Task, error)
- func (m *MockV1) SyncProbes(arg0 context.Context, arg1 *scheduler.SyncProbesRequest, ...) (scheduler.Scheduler_SyncProbesClient, error)
- type MockV1MockRecorder
- func (mr *MockV1MockRecorder) AnnounceHost(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) AnnounceTask(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) Close() *gomock.Call
- func (mr *MockV1MockRecorder) LeaveHost(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) LeaveTask(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) RegisterPeerTask(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) ReportPeerResult(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) ReportPieceResult(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) StatTask(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV1MockRecorder) SyncProbes(arg0, arg1 any, arg2 ...any) *gomock.Call
- type MockV2
- func (m *MockV2) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest, ...) error
- func (m *MockV2) AnnouncePeer(arg0 context.Context, arg1 string, arg2 ...grpc.CallOption) (scheduler.Scheduler_AnnouncePeerClient, error)
- func (m *MockV2) Close() error
- func (m *MockV2) EXPECT() *MockV2MockRecorder
- func (m *MockV2) ExchangePeer(arg0 context.Context, arg1 *scheduler.ExchangePeerRequest, ...) (*scheduler.ExchangePeerResponse, error)
- func (m *MockV2) LeaveHost(arg0 context.Context, arg1 *scheduler.LeaveHostRequest, ...) error
- func (m *MockV2) LeavePeer(arg0 context.Context, arg1 *scheduler.LeavePeerRequest, ...) error
- func (m *MockV2) StatPeer(arg0 context.Context, arg1 *scheduler.StatPeerRequest, arg2 ...grpc.CallOption) (*common.Peer, error)
- func (m *MockV2) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*common.Task, error)
- func (m *MockV2) SyncProbes(arg0 context.Context, arg1 *scheduler.SyncProbesRequest, ...) (scheduler.Scheduler_SyncProbesClient, error)
- type MockV2MockRecorder
- func (mr *MockV2MockRecorder) AnnounceHost(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) AnnouncePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) Close() *gomock.Call
- func (mr *MockV2MockRecorder) ExchangePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) LeaveHost(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) LeavePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) StatPeer(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) StatTask(arg0, arg1 any, arg2 ...any) *gomock.Call
- func (mr *MockV2MockRecorder) SyncProbes(arg0, arg1 any, arg2 ...any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockV1 ¶ added in v2.0.9
type MockV1 struct {
// contains filtered or unexported fields
}
MockV1 is a mock of V1 interface.
func NewMockV1 ¶ added in v2.0.9
func NewMockV1(ctrl *gomock.Controller) *MockV1
NewMockV1 creates a new mock instance.
func (*MockV1) AnnounceHost ¶ added in v2.0.9
func (m *MockV1) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest, arg2 ...grpc.CallOption) error
AnnounceHost mocks base method.
func (*MockV1) AnnounceTask ¶ added in v2.0.9
func (m *MockV1) AnnounceTask(arg0 context.Context, arg1 *scheduler.AnnounceTaskRequest, arg2 ...grpc.CallOption) error
AnnounceTask mocks base method.
func (*MockV1) EXPECT ¶ added in v2.0.9
func (m *MockV1) EXPECT() *MockV1MockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockV1) LeaveHost ¶ added in v2.0.9
func (m *MockV1) LeaveHost(arg0 context.Context, arg1 *scheduler.LeaveHostRequest, arg2 ...grpc.CallOption) error
LeaveHost mocks base method.
func (*MockV1) LeaveTask ¶ added in v2.0.9
func (m *MockV1) LeaveTask(arg0 context.Context, arg1 *scheduler.PeerTarget, arg2 ...grpc.CallOption) error
LeaveTask mocks base method.
func (*MockV1) RegisterPeerTask ¶ added in v2.0.9
func (m *MockV1) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (*scheduler.RegisterResult, error)
RegisterPeerTask mocks base method.
func (*MockV1) ReportPeerResult ¶ added in v2.0.9
func (m *MockV1) ReportPeerResult(arg0 context.Context, arg1 *scheduler.PeerResult, arg2 ...grpc.CallOption) error
ReportPeerResult mocks base method.
func (*MockV1) ReportPieceResult ¶ added in v2.0.9
func (m *MockV1) ReportPieceResult(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_ReportPieceResultClient, error)
ReportPieceResult mocks base method.
func (*MockV1) StatTask ¶ added in v2.0.9
func (m *MockV1) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*scheduler.Task, error)
StatTask mocks base method.
func (*MockV1) SyncProbes ¶ added in v2.0.9
func (m *MockV1) SyncProbes(arg0 context.Context, arg1 *scheduler.SyncProbesRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_SyncProbesClient, error)
SyncProbes mocks base method.
type MockV1MockRecorder ¶ added in v2.0.9
type MockV1MockRecorder struct {
// contains filtered or unexported fields
}
MockV1MockRecorder is the mock recorder for MockV1.
func (*MockV1MockRecorder) AnnounceHost ¶ added in v2.0.9
func (mr *MockV1MockRecorder) AnnounceHost(arg0, arg1 any, arg2 ...any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockV1MockRecorder) AnnounceTask ¶ added in v2.0.9
func (mr *MockV1MockRecorder) AnnounceTask(arg0, arg1 any, arg2 ...any) *gomock.Call
AnnounceTask indicates an expected call of AnnounceTask.
func (*MockV1MockRecorder) Close ¶ added in v2.0.9
func (mr *MockV1MockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockV1MockRecorder) LeaveHost ¶ added in v2.0.9
func (mr *MockV1MockRecorder) LeaveHost(arg0, arg1 any, arg2 ...any) *gomock.Call
LeaveHost indicates an expected call of LeaveHost.
func (*MockV1MockRecorder) LeaveTask ¶ added in v2.0.9
func (mr *MockV1MockRecorder) LeaveTask(arg0, arg1 any, arg2 ...any) *gomock.Call
LeaveTask indicates an expected call of LeaveTask.
func (*MockV1MockRecorder) RegisterPeerTask ¶ added in v2.0.9
func (mr *MockV1MockRecorder) RegisterPeerTask(arg0, arg1 any, arg2 ...any) *gomock.Call
RegisterPeerTask indicates an expected call of RegisterPeerTask.
func (*MockV1MockRecorder) ReportPeerResult ¶ added in v2.0.9
func (mr *MockV1MockRecorder) ReportPeerResult(arg0, arg1 any, arg2 ...any) *gomock.Call
ReportPeerResult indicates an expected call of ReportPeerResult.
func (*MockV1MockRecorder) ReportPieceResult ¶ added in v2.0.9
func (mr *MockV1MockRecorder) ReportPieceResult(arg0, arg1 any, arg2 ...any) *gomock.Call
ReportPieceResult indicates an expected call of ReportPieceResult.
func (*MockV1MockRecorder) StatTask ¶ added in v2.0.9
func (mr *MockV1MockRecorder) StatTask(arg0, arg1 any, arg2 ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockV1MockRecorder) SyncProbes ¶ added in v2.0.9
func (mr *MockV1MockRecorder) SyncProbes(arg0, arg1 any, arg2 ...any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.
type MockV2 ¶ added in v2.0.9
type MockV2 struct {
// contains filtered or unexported fields
}
MockV2 is a mock of V2 interface.
func NewMockV2 ¶ added in v2.0.9
func NewMockV2(ctrl *gomock.Controller) *MockV2
NewMockV2 creates a new mock instance.
func (*MockV2) AnnounceHost ¶ added in v2.0.9
func (m *MockV2) AnnounceHost(arg0 context.Context, arg1 *scheduler.AnnounceHostRequest, arg2 ...grpc.CallOption) error
AnnounceHost mocks base method.
func (*MockV2) AnnouncePeer ¶ added in v2.0.9
func (m *MockV2) AnnouncePeer(arg0 context.Context, arg1 string, arg2 ...grpc.CallOption) (scheduler.Scheduler_AnnouncePeerClient, error)
AnnouncePeer mocks base method.
func (*MockV2) EXPECT ¶ added in v2.0.9
func (m *MockV2) EXPECT() *MockV2MockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockV2) ExchangePeer ¶ added in v2.0.9
func (m *MockV2) ExchangePeer(arg0 context.Context, arg1 *scheduler.ExchangePeerRequest, arg2 ...grpc.CallOption) (*scheduler.ExchangePeerResponse, error)
ExchangePeer mocks base method.
func (*MockV2) LeaveHost ¶ added in v2.0.9
func (m *MockV2) LeaveHost(arg0 context.Context, arg1 *scheduler.LeaveHostRequest, arg2 ...grpc.CallOption) error
LeaveHost mocks base method.
func (*MockV2) LeavePeer ¶ added in v2.0.9
func (m *MockV2) LeavePeer(arg0 context.Context, arg1 *scheduler.LeavePeerRequest, arg2 ...grpc.CallOption) error
LeavePeer mocks base method.
func (*MockV2) StatPeer ¶ added in v2.0.9
func (m *MockV2) StatPeer(arg0 context.Context, arg1 *scheduler.StatPeerRequest, arg2 ...grpc.CallOption) (*common.Peer, error)
StatPeer mocks base method.
func (*MockV2) StatTask ¶ added in v2.0.9
func (m *MockV2) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*common.Task, error)
StatTask mocks base method.
func (*MockV2) SyncProbes ¶ added in v2.0.9
func (m *MockV2) SyncProbes(arg0 context.Context, arg1 *scheduler.SyncProbesRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_SyncProbesClient, error)
SyncProbes mocks base method.
type MockV2MockRecorder ¶ added in v2.0.9
type MockV2MockRecorder struct {
// contains filtered or unexported fields
}
MockV2MockRecorder is the mock recorder for MockV2.
func (*MockV2MockRecorder) AnnounceHost ¶ added in v2.0.9
func (mr *MockV2MockRecorder) AnnounceHost(arg0, arg1 any, arg2 ...any) *gomock.Call
AnnounceHost indicates an expected call of AnnounceHost.
func (*MockV2MockRecorder) AnnouncePeer ¶ added in v2.0.9
func (mr *MockV2MockRecorder) AnnouncePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
AnnouncePeer indicates an expected call of AnnouncePeer.
func (*MockV2MockRecorder) Close ¶ added in v2.0.9
func (mr *MockV2MockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockV2MockRecorder) ExchangePeer ¶ added in v2.0.9
func (mr *MockV2MockRecorder) ExchangePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
ExchangePeer indicates an expected call of ExchangePeer.
func (*MockV2MockRecorder) LeaveHost ¶ added in v2.0.9
func (mr *MockV2MockRecorder) LeaveHost(arg0, arg1 any, arg2 ...any) *gomock.Call
LeaveHost indicates an expected call of LeaveHost.
func (*MockV2MockRecorder) LeavePeer ¶ added in v2.0.9
func (mr *MockV2MockRecorder) LeavePeer(arg0, arg1 any, arg2 ...any) *gomock.Call
LeavePeer indicates an expected call of LeavePeer.
func (*MockV2MockRecorder) StatPeer ¶ added in v2.0.9
func (mr *MockV2MockRecorder) StatPeer(arg0, arg1 any, arg2 ...any) *gomock.Call
StatPeer indicates an expected call of StatPeer.
func (*MockV2MockRecorder) StatTask ¶ added in v2.0.9
func (mr *MockV2MockRecorder) StatTask(arg0, arg1 any, arg2 ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockV2MockRecorder) SyncProbes ¶ added in v2.0.9
func (mr *MockV2MockRecorder) SyncProbes(arg0, arg1 any, arg2 ...any) *gomock.Call
SyncProbes indicates an expected call of SyncProbes.