mocks

Documentation

Overview

Package mocks is a generated GoMock package.

Index

• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (m *MockClient) AnnounceTask(arg0 context.Context, arg1 *scheduler.AnnounceTaskRequest, ...) error
  • func (m *MockClient) Close() error
  • func (m *MockClient) EXPECT() *MockClientMockRecorder
  • func (m *MockClient) GetState() []dfnet.NetAddr
  • func (m *MockClient) LeaveTask(arg0 context.Context, arg1 *scheduler.PeerTarget, arg2 ...grpc.CallOption) error
  • func (m *MockClient) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (*scheduler.RegisterResult, error)
  • func (m *MockClient) ReportPeerResult(arg0 context.Context, arg1 *scheduler.PeerResult, arg2 ...grpc.CallOption) error
  • func (m *MockClient) ReportPieceResult(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_ReportPieceResultClient, error)
  • func (m *MockClient) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*scheduler.Task, error)
  • func (m *MockClient) UpdateState(arg0 []dfnet.NetAddr)
• type MockClientMockRecorder
  • func (mr *MockClientMockRecorder) AnnounceTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) Close() *gomock.Call
  • func (mr *MockClientMockRecorder) GetState() *gomock.Call
  • func (mr *MockClientMockRecorder) LeaveTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) RegisterPeerTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) ReportPeerResult(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) ReportPieceResult(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) StatTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) UpdateState(arg0 interface{}) *gomock.Call

Types

type MockClient

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

MockClient is a mock of Client interface.

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) AnnounceTask

func (m *MockClient) AnnounceTask(arg0 context.Context, arg1 *scheduler.AnnounceTaskRequest, arg2 ...grpc.CallOption) error

AnnounceTask mocks base method.

func (*MockClient) Close

func (m *MockClient) Close() error

Close mocks base method.

func (*MockClient) EXPECT

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) GetState

func (m *MockClient) GetState() []dfnet.NetAddr

GetState mocks base method.

func (*MockClient) LeaveTask

func (m *MockClient) LeaveTask(arg0 context.Context, arg1 *scheduler.PeerTarget, arg2 ...grpc.CallOption) error

LeaveTask mocks base method.

func (*MockClient) RegisterPeerTask

func (m *MockClient) RegisterPeerTask(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (*scheduler.RegisterResult, error)

RegisterPeerTask mocks base method.

func (*MockClient) ReportPeerResult

func (m *MockClient) ReportPeerResult(arg0 context.Context, arg1 *scheduler.PeerResult, arg2 ...grpc.CallOption) error

ReportPeerResult mocks base method.

func (*MockClient) ReportPieceResult

func (m *MockClient) ReportPieceResult(arg0 context.Context, arg1 *scheduler.PeerTaskRequest, arg2 ...grpc.CallOption) (scheduler.Scheduler_ReportPieceResultClient, error)

ReportPieceResult mocks base method.

func (*MockClient) StatTask

func (m *MockClient) StatTask(arg0 context.Context, arg1 *scheduler.StatTaskRequest, arg2 ...grpc.CallOption) (*scheduler.Task, error)

StatTask mocks base method.

func (*MockClient) UpdateState

func (m *MockClient) UpdateState(arg0 []dfnet.NetAddr)

UpdateState mocks base method.

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) AnnounceTask

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

AnnounceTask indicates an expected call of AnnounceTask.

func (*MockClientMockRecorder) Close

func (mr *MockClientMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClientMockRecorder) GetState

func (mr *MockClientMockRecorder) GetState() *gomock.Call

GetState indicates an expected call of GetState.

func (*MockClientMockRecorder) LeaveTask

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

LeaveTask indicates an expected call of LeaveTask.

func (*MockClientMockRecorder) RegisterPeerTask

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

RegisterPeerTask indicates an expected call of RegisterPeerTask.

func (*MockClientMockRecorder) ReportPeerResult

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

ReportPeerResult indicates an expected call of ReportPeerResult.

func (*MockClientMockRecorder) ReportPieceResult

func (mr *MockClientMockRecorder) ReportPieceResult(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ReportPieceResult indicates an expected call of ReportPieceResult.

func (*MockClientMockRecorder) StatTask

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

StatTask indicates an expected call of StatTask.

func (*MockClientMockRecorder) UpdateState

func (mr *MockClientMockRecorder) UpdateState(arg0 interface{}) *gomock.Call

UpdateState indicates an expected call of UpdateState.