client

Documentation

Index

• type DownloaderClient
  • func NewDownloaderClient(address string) (*DownloaderClient, error)
  • func (client *DownloaderClient) Close() error
  • func (client *DownloaderClient) GetBucketReadQuota(ctx context.Context, bucketInfo *storagetypes.BucketInfo, yearMonth string, ...) (*types.GetBucketReadQuotaResponse, error)
  • func (client *DownloaderClient) GetEndpointBySpAddress(ctx context.Context, spAddress string, opts ...grpc.CallOption) (string, error)
  • func (client *DownloaderClient) GetObject(ctx context.Context, req *types.GetObjectRequest, opts ...grpc.CallOption) (types.DownloaderService_GetObjectClient, error)
  • func (client *DownloaderClient) ListBucketReadRecord(ctx context.Context, bucketInfo *storagetypes.BucketInfo, ...) (*types.ListBucketReadRecordResponse, error)

Types

type DownloaderClient

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

DownloaderClient is a downloader gRPC service client wrapper

func NewDownloaderClient

func NewDownloaderClient(address string) (*DownloaderClient, error)

NewDownloaderClient returns a DownloaderClient instance

func (*DownloaderClient) Close

func (client *DownloaderClient) Close() error

Close the download gPRC connection

func (*DownloaderClient) GetBucketReadQuota

func (client *DownloaderClient) GetBucketReadQuota(ctx context.Context, bucketInfo *storagetypes.BucketInfo, yearMonth string, opts ...grpc.CallOption) (*types.GetBucketReadQuotaResponse, error)

GetBucketReadQuota gets the quota info of the specified month

func (*DownloaderClient) GetEndpointBySpAddress

func (client *DownloaderClient) GetEndpointBySpAddress(ctx context.Context, spAddress string, opts ...grpc.CallOption) (string, error)

GetEndpointBySpAddress get endpoint by sp address

func (*DownloaderClient) GetObject

func (client *DownloaderClient) GetObject(ctx context.Context, req *types.GetObjectRequest,
	opts ...grpc.CallOption) (types.DownloaderService_GetObjectClient, error)

GetObject downloads the payload of the object

func (*DownloaderClient) ListBucketReadRecord

func (client *DownloaderClient) ListBucketReadRecord(ctx context.Context, bucketInfo *storagetypes.BucketInfo, startTimestampUs, endTimestampUs, maxRecordNum int64, opts ...grpc.CallOption) (*types.ListBucketReadRecordResponse, error)

ListBucketReadRecord get read record list of the specified time range