client

Documentation

Index

• type V1
  • func GetInsecureV1(ctx context.Context, target string, opts ...grpc.DialOption) (V1, error)
  • func GetV1(ctx context.Context, target string, opts ...grpc.DialOption) (V1, error)
• type V2
  • func GetV2(ctx context.Context, target string, opts ...grpc.DialOption) (V2, error)

Types

type V1

type V1 interface {
	// Trigger client to download file.
	Download(context.Context, *dfdaemonv1.DownRequest, ...grpc.CallOption) (dfdaemonv1.Daemon_DownloadClient, error)

	// Get piece tasks from other peers.
	GetPieceTasks(context.Context, *commonv1.PieceTaskRequest, ...grpc.CallOption) (*commonv1.PiecePacket, error)

	// Sync piece tasks with other peers.
	SyncPieceTasks(context.Context, *commonv1.PieceTaskRequest, ...grpc.CallOption) (dfdaemonv1.Daemon_SyncPieceTasksClient, error)

	// Check if given task exists in P2P cache system.
	StatTask(context.Context, *dfdaemonv1.StatTaskRequest, ...grpc.CallOption) error

	// Import the given file into P2P cache system.
	ImportTask(context.Context, *dfdaemonv1.ImportTaskRequest, ...grpc.CallOption) error

	// Export or download file from P2P cache system.
	ExportTask(context.Context, *dfdaemonv1.ExportTaskRequest, ...grpc.CallOption) error

	// Delete file from P2P cache system.
	DeleteTask(context.Context, *dfdaemonv1.DeleteTaskRequest, ...grpc.CallOption) error

	// Check daemon health.
	CheckHealth(context.Context, ...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 GetInsecureV1

func GetInsecureV1(ctx context.Context, target string, opts ...grpc.DialOption) (V1, error)

GetInsecureV1 returns v1 version of the dfdaemon client. FIXME use GetV1 and insecure.NewCredentials instead of this function

func GetV1

func GetV1(ctx context.Context, target string, opts ...grpc.DialOption) (V1, error)

GetV1 returns v1 version of the dfdaemon client.

type V2

type V2 interface {
	// SyncPieces syncs pieces from the other peers.
	DownloadPiece(context.Context, *dfdaemonv2.DownloadPieceRequest, ...grpc.CallOption) (*dfdaemonv2.DownloadPieceResponse, error)

	// DownloadTask downloads task back-to-source.
	DownloadTask(context.Context, *dfdaemonv2.DownloadTaskRequest, ...grpc.CallOption) error

	// UploadTask uploads task to p2p network.
	UploadTask(context.Context, *dfdaemonv2.UploadTaskRequest, ...grpc.CallOption) error

	// StatTask stats task information.
	StatTask(context.Context, *dfdaemonv2.StatTaskRequest, ...grpc.CallOption) (*commonv2.Task, error)

	// DeleteTask deletes task from p2p network.
	DeleteTask(context.Context, *dfdaemonv2.DeleteTaskRequest, ...grpc.CallOption) error

	// Close tears down the ClientConn and all underlying connections.
	Close() error
}

V2 is the interface for v2 version of the grpc client.

func GetV2

func GetV2(ctx context.Context, target string, opts ...grpc.DialOption) (V2, error)

GetV2 returns v2 version of the dfdaemon client.