client

Documentation

Index

• func GetPieceTasks(ctx context.Context, dstPeer *schedulerv1.PeerPacket_DestPeer, ...) (*commonv1.PiecePacket, error)
• func SyncPieceTasks(ctx context.Context, destPeer *schedulerv1.PeerPacket_DestPeer, ...) (dfdaemonv1.Daemon_SyncPieceTasksClient, error)
• type DaemonClient
  • func GetClientByAddr(addrs []dfnet.NetAddr, opts ...grpc.DialOption) (DaemonClient, error)
  • func GetElasticClientByAddrs(addrs []dfnet.NetAddr, opts ...grpc.DialOption) (DaemonClient, error)
• type DownResultStream
  • func (drs *DownResultStream) Recv() (dr *dfdaemonv1.DownResult, err error)

Functions

func GetPieceTasks

func GetPieceTasks(ctx context.Context,
	dstPeer *schedulerv1.PeerPacket_DestPeer,
	ptr *commonv1.PieceTaskRequest,
	opts ...grpc.CallOption) (*commonv1.PiecePacket, error)

func SyncPieceTasks

func SyncPieceTasks(ctx context.Context,
	destPeer *schedulerv1.PeerPacket_DestPeer,
	ptr *commonv1.PieceTaskRequest,
	opts ...grpc.CallOption) (dfdaemonv1.Daemon_SyncPieceTasksClient, error)

Types

type DaemonClient

type DaemonClient interface {
	Download(ctx context.Context, req *dfdaemonv1.DownRequest, opts ...grpc.CallOption) (*DownResultStream, error)

	GetPieceTasks(ctx context.Context, addr dfnet.NetAddr, ptr *commonv1.PieceTaskRequest, opts ...grpc.CallOption) (*commonv1.PiecePacket, error)

	SyncPieceTasks(ctx context.Context, addr dfnet.NetAddr, ptr *commonv1.PieceTaskRequest, opts ...grpc.CallOption) (dfdaemonv1.Daemon_SyncPieceTasksClient, error)

	CheckHealth(ctx context.Context, target dfnet.NetAddr, opts ...grpc.CallOption) error

	StatTask(ctx context.Context, req *dfdaemonv1.StatTaskRequest, opts ...grpc.CallOption) error

	ImportTask(ctx context.Context, req *dfdaemonv1.ImportTaskRequest, opts ...grpc.CallOption) error

	ExportTask(ctx context.Context, req *dfdaemonv1.ExportTaskRequest, opts ...grpc.CallOption) error

	DeleteTask(ctx context.Context, req *dfdaemonv1.DeleteTaskRequest, opts ...grpc.CallOption) error

	Close() error
}

DaemonClient see dfdaemonv1.DaemonClient

func GetClientByAddr

func GetClientByAddr(addrs []dfnet.NetAddr, opts ...grpc.DialOption) (DaemonClient, error)

func GetElasticClientByAddrs

func GetElasticClientByAddrs(addrs []dfnet.NetAddr, opts ...grpc.DialOption) (DaemonClient, error)

type DownResultStream

type DownResultStream struct {
	rpc.RetryMeta
	// contains filtered or unexported fields
}

func (*DownResultStream) Recv

func (drs *DownResultStream) Recv() (dr *dfdaemonv1.DownResult, err error)