client

Documentation

Index

• type UploaderClient
  • func NewUploaderClient(address string) (*UploaderClient, error)
  • func (client *UploaderClient) Close() error
  • func (client *UploaderClient) PutObject(ctx context.Context, opts ...grpc.CallOption) (types.UploaderService_PutObjectClient, error)
  • func (client *UploaderClient) QueryPuttingObject(ctx context.Context, objectID uint64, opts ...grpc.CallOption) (*servicetypes.SegmentInfo, error)

Types

type UploaderClient

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

UploaderClient is an uploader gRPC service client wrapper

func NewUploaderClient

func NewUploaderClient(address string) (*UploaderClient, error)

NewUploaderClient return an UploaderClient instance

func (*UploaderClient) Close

func (client *UploaderClient) Close() error

Close the uploader gRPC client connection

func (*UploaderClient) PutObject

func (client *UploaderClient) PutObject(ctx context.Context, opts ...grpc.CallOption) (types.UploaderService_PutObjectClient, error)

PutObject return grpc stream client, and be used to upload object payload.

func (*UploaderClient) QueryPuttingObject

func (client *UploaderClient) QueryPuttingObject(ctx context.Context, objectID uint64, opts ...grpc.CallOption) (
	*servicetypes.SegmentInfo, error)

QueryPuttingObject query a putting object info with object id