client

Documentation

Index

• type ReceiverClient
  • func NewReceiverClient(address string) (*ReceiverClient, error)
  • func (client *ReceiverClient) Close() error
  • func (client *ReceiverClient) QuerySyncingObject(ctx context.Context, objectID uint64) (*servicetypes.SegmentInfo, error)
  • func (client *ReceiverClient) SyncObject(ctx context.Context, opts ...grpc.CallOption) (types.ReceiverService_SyncObjectClient, 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) QuerySyncingObject

func (client *ReceiverClient) QuerySyncingObject(ctx context.Context, objectID uint64) (*servicetypes.SegmentInfo, error)

QuerySyncingObject a syncing object info by object id

func (*ReceiverClient) SyncObject

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

SyncObject an object payload with object info