client

Documentation

Index

• type ReceiverClient
  • func NewReceiverClient(address string) (*ReceiverClient, error)
  • func (client *ReceiverClient) Close() error
  • func (client *ReceiverClient) QueryReceivingObject(ctx context.Context, objectID uint64) (*servicetypes.PieceInfo, error)
  • func (client *ReceiverClient) ReceiveObjectPiece(ctx context.Context, opts ...grpc.CallOption) (types.ReceiverService_ReceiveObjectPieceClient, error)

Types

type ReceiverClient

type ReceiverClient struct {
	// contains filtered or unexported fields
}

ReceiverClient is a receiver gRPC service client wrapper

func NewReceiverClient

func NewReceiverClient(address string) (*ReceiverClient, error)

NewReceiverClient return a ReceiverClient instance

func (*ReceiverClient) Close

func (client *ReceiverClient) Close() error

Close the receiver gPRC connection

func (*ReceiverClient) QueryReceivingObject

func (client *ReceiverClient) QueryReceivingObject(ctx context.Context, objectID uint64) (*servicetypes.PieceInfo, error)

QueryReceivingObject a syncing object info by object id

func (*ReceiverClient) ReceiveObjectPiece

func (client *ReceiverClient) ReceiveObjectPiece(ctx context.Context, opts ...grpc.CallOption) (
	types.ReceiverService_ReceiveObjectPieceClient, error)

ReceiveObjectPiece an object payload with object info