mocks

package
v2.0.5 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2022 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) AnnounceTask added in v2.0.3 

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

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

StatTask mocks base method.

type MockSchedulerClientMockRecorder 

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

MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.

func (*MockSchedulerClientMockRecorder) AnnounceTask added in v2.0.3 

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

AnnounceTask indicates an expected call of AnnounceTask.

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 added in v2.0.3 

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

StatTask indicates an expected call of StatTask.

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) AnnounceTask added in v2.0.3 

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

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

StatTask mocks base method.

type MockSchedulerServerMockRecorder 

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

MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.

func (*MockSchedulerServerMockRecorder) AnnounceTask added in v2.0.3 

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

AnnounceTask indicates an expected call of AnnounceTask.

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 added in v2.0.3 

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

StatTask indicates an expected call of StatTask.

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 MockisPeerPacket_ErrorDetail added in v2.0.5 

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

MockisPeerPacket_ErrorDetail is a mock of isPeerPacket_ErrorDetail interface.

func NewMockisPeerPacket_ErrorDetail added in v2.0.5 

func NewMockisPeerPacket_ErrorDetail(ctrl *gomock.Controller) *MockisPeerPacket_ErrorDetail

NewMockisPeerPacket_ErrorDetail creates a new mock instance.

func (*MockisPeerPacket_ErrorDetail) EXPECT added in v2.0.5 

func (m *MockisPeerPacket_ErrorDetail) EXPECT() *MockisPeerPacket_ErrorDetailMockRecorder

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

type MockisPeerPacket_ErrorDetailMockRecorder added in v2.0.5 

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

MockisPeerPacket_ErrorDetailMockRecorder is the mock recorder for MockisPeerPacket_ErrorDetail.

type MockisPeerResult_ErrorDetail added in v2.0.5 

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

MockisPeerResult_ErrorDetail is a mock of isPeerResult_ErrorDetail interface.

func NewMockisPeerResult_ErrorDetail added in v2.0.5 

func NewMockisPeerResult_ErrorDetail(ctrl *gomock.Controller) *MockisPeerResult_ErrorDetail

NewMockisPeerResult_ErrorDetail creates a new mock instance.

func (*MockisPeerResult_ErrorDetail) EXPECT added in v2.0.5 

func (m *MockisPeerResult_ErrorDetail) EXPECT() *MockisPeerResult_ErrorDetailMockRecorder

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

type MockisPeerResult_ErrorDetailMockRecorder added in v2.0.5 

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

MockisPeerResult_ErrorDetailMockRecorder is the mock recorder for MockisPeerResult_ErrorDetail.

type MockisRegisterResult_DirectPiece 

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

MockisRegisterResult_DirectPiece is a mock of isRegisterResult_DirectPiece interface.

func NewMockisRegisterResult_DirectPiece 

func NewMockisRegisterResult_DirectPiece(ctrl *gomock.Controller) *MockisRegisterResult_DirectPiece

NewMockisRegisterResult_DirectPiece creates a new mock instance.

func (*MockisRegisterResult_DirectPiece) EXPECT 

func (m *MockisRegisterResult_DirectPiece) EXPECT() *MockisRegisterResult_DirectPieceMockRecorder

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

type MockisRegisterResult_DirectPieceMockRecorder 

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

MockisRegisterResult_DirectPieceMockRecorder is the mock recorder for MockisRegisterResult_DirectPiece.

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.