client

Documentation

Index

• type Client
  • func GetClient(ctx context.Context, target string, opts ...grpc.DialOption) (Client, error)
  • func GetInsecureClient(ctx context.Context, target string, opts ...grpc.DialOption) (Client, error)

Types

type Client

type Client 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
}

Client is the interface for grpc client.

func GetClient

func GetClient(ctx context.Context, target string, opts ...grpc.DialOption) (Client, error)

GetClient returns dfdaemon client.

func GetInsecureClient

func GetInsecureClient(ctx context.Context, target string, opts ...grpc.DialOption) (Client, error)

GetInsecureClient returns dfdaemon client. FIXME use GetClient + insecure.NewCredentials instead of this function