receiver

Documentation

Index

• type Receiver
  • func NewReceiverService(config *ReceiverConfig) (*Receiver, error)
  • func (receiver *Receiver) Name() string
  • func (receiver *Receiver) QueryReceivingObject(ctx context.Context, req *types.QueryReceivingObjectRequest) (resp *types.QueryReceivingObjectResponse, err error)
  • func (receiver *Receiver) ReceiveObjectPiece(stream types.ReceiverService_ReceiveObjectPieceServer) (err error)
  • func (receiver *Receiver) Start(ctx context.Context) error
  • func (receiver *Receiver) Stop(ctx context.Context) error
• type ReceiverConfig

Types

type Receiver

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

Receiver implements the gRPC of ReceiverService, responsible for receive replicate object payload data

func NewReceiverService

func NewReceiverService(config *ReceiverConfig) (*Receiver, error)

NewReceiverService return a Receiver instance and init the resource

func (*Receiver) Name

func (receiver *Receiver) Name() string

Name return the receiver service name, for the lifecycle management

func (*Receiver) QueryReceivingObject

func (receiver *Receiver) QueryReceivingObject(ctx context.Context, req *types.QueryReceivingObjectRequest) (
	resp *types.QueryReceivingObjectResponse, err error)

QueryReceivingObject query a receiving object info by object id.

func (*Receiver) ReceiveObjectPiece

func (receiver *Receiver) ReceiveObjectPiece(stream types.ReceiverService_ReceiveObjectPieceServer) (err error)

ReceiveObjectPiece an object payload to storage provider.

func (*Receiver) Start

func (receiver *Receiver) Start(ctx context.Context) error

Start the receiver background goroutine

func (*Receiver) Stop

func (receiver *Receiver) Stop(ctx context.Context) error

Stop the receiver gRPC service and recycle the resources

type ReceiverConfig

type ReceiverConfig struct {
	SpOperatorAddress string
	GRPCAddress       string
	SignerGRPCAddress string
	SpDBConfig        *config.SQLDBConfig
	PieceStoreConfig  *storage.PieceStoreConfig
}