client

Documentation

Index

• func NewBeginOfPiece(taskID, peerID string) *schedulerv1.PieceResult
• func NewEndOfPiece(taskID, peerID string, finishedCount int32) *schedulerv1.PieceResult
• type Client
  • func GetClient(dynconfig config.Dynconfig, options ...grpc.DialOption) (Client, error)

Functions

func NewBeginOfPiece

func NewBeginOfPiece(taskID, peerID string) *schedulerv1.PieceResult

NewBeginOfPiece creates begin of piece.

func NewEndOfPiece

func NewEndOfPiece(taskID, peerID string, finishedCount int32) *schedulerv1.PieceResult

NewBeginOfPiece creates end of piece.

Types

type Client

type Client interface {
	// RegisterPeerTask registers a peer into task.
	RegisterPeerTask(context.Context, *schedulerv1.PeerTaskRequest, ...grpc.CallOption) (*schedulerv1.RegisterResult, error)

	// ReportPieceResult reports piece results and receives peer packets.
	ReportPieceResult(context.Context, *schedulerv1.PeerTaskRequest, ...grpc.CallOption) (schedulerv1.Scheduler_ReportPieceResultClient, error)

	// ReportPeerResult reports downloading result for the peer.
	ReportPeerResult(context.Context, *schedulerv1.PeerResult, ...grpc.CallOption) error

	// LeaveTask makes the peer leaving from task.
	LeaveTask(context.Context, *schedulerv1.PeerTarget, ...grpc.CallOption) error

	// Checks if any peer has the given task.
	StatTask(context.Context, *schedulerv1.StatTaskRequest, ...grpc.CallOption) (*schedulerv1.Task, error)

	// A peer announces that it has the announced task to other peers.
	AnnounceTask(context.Context, *schedulerv1.AnnounceTaskRequest, ...grpc.CallOption) error

	// Close grpc service.
	Close() error
}

Client is the interface for grpc client.

func GetClient

func GetClient(dynconfig config.Dynconfig, options ...grpc.DialOption) (Client, error)

GetClient get scheduler clients using resolver and balancer,