Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type V1 ¶ added in v2.0.9
type V1 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
// A peer announces that it has the announced task to other peers.
AnnounceTask(context.Context, *schedulerv1.AnnounceTaskRequest, ...grpc.CallOption) error
// Checks if any peer has the given task.
StatTask(context.Context, *schedulerv1.StatTaskRequest, ...grpc.CallOption) (*schedulerv1.Task, error)
// LeaveTask releases peer in scheduler.
LeaveTask(context.Context, *schedulerv1.PeerTarget, ...grpc.CallOption) error
// AnnounceHost announces host to scheduler.
AnnounceHost(context.Context, *schedulerv1.AnnounceHostRequest, ...grpc.CallOption) error
// LeaveHost releases host in scheduler.
LeaveHost(context.Context, *schedulerv1.LeaveHostRequest, ...grpc.CallOption) error
// Close tears down the ClientConn and all underlying connections.
Close() error
}
V1 is the interface for v1 version of the grpc client.
func GetV1ByAddr ¶ added in v2.0.9
GetV1ByAddr returns v1 version of the scheduler client by address.
type V2 ¶ added in v2.0.9
type V2 interface {
// AnnouncePeer announces peer to scheduler.
AnnouncePeer(context.Context, string, ...grpc.CallOption) (schedulerv2.Scheduler_AnnouncePeerClient, error)
// Checks information of peer.
StatPeer(context.Context, *schedulerv2.StatPeerRequest, ...grpc.CallOption) (*commonv2.Peer, error)
// DeletePeer releases peer in scheduler.
DeletePeer(context.Context, *schedulerv2.DeletePeerRequest, ...grpc.CallOption) error
// Checks information of task.
StatTask(context.Context, *schedulerv2.StatTaskRequest, ...grpc.CallOption) (*commonv2.Task, error)
// DeleteTask releases task in scheduler.
DeleteTask(context.Context, *schedulerv2.DeleteTaskRequest, ...grpc.CallOption) error
// AnnounceHost announces host to scheduler.
AnnounceHost(context.Context, *schedulerv2.AnnounceHostRequest, ...grpc.CallOption) error
// ListHosts lists hosts in scheduler.
ListHosts(ctx context.Context, taskID string, req *schedulerv2.ListHostsRequest, opts ...grpc.CallOption) (*schedulerv2.ListHostsResponse, error)
// DeleteHost releases host in scheduler.
DeleteHost(context.Context, *schedulerv2.DeleteHostRequest, ...grpc.CallOption) error
// Close tears down the ClientConn and all underlying connections.
Close() error
}
V2 is the interface for v1 version of the grpc client.
func GetV2ByAddr ¶ added in v2.0.9
GetV2ByAddr returns v2 version of the scheduler client by address.
Click to show internal directories.
Click to hide internal directories.