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 // SyncProbes sync probes of the host. SyncProbes(context.Context, *schedulerv1.SyncProbesRequest, ...grpc.CallOption) (schedulerv1.Scheduler_SyncProbesClient, 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 v2 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 // DeleteHost releases host in scheduler. DeleteHost(context.Context, *schedulerv2.DeleteHostRequest, ...grpc.CallOption) error // SyncProbes sync probes of the host. SyncProbes(context.Context, *schedulerv2.SyncProbesRequest, ...grpc.CallOption) (schedulerv2.Scheduler_SyncProbesClient, 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.