receiver

Documentation

Index

• type Receiver
  • func NewReceiverService(config *ReceiverConfig) (*Receiver, error)
  • func (receiver *Receiver) Name() string
  • func (receiver *Receiver) QuerySyncingObject(ctx context.Context, req *types.QuerySyncingObjectRequest) (resp *types.QuerySyncingObjectResponse, err error)
  • func (receiver *Receiver) Start(ctx context.Context) error
  • func (receiver *Receiver) Stop(ctx context.Context) error
  • func (receiver *Receiver) SyncObject(stream types.ReceiverService_SyncObjectServer) (err 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) QuerySyncingObject

func (receiver *Receiver) QuerySyncingObject(ctx context.Context, req *types.QuerySyncingObjectRequest) (
	resp *types.QuerySyncingObjectResponse, err error)

QuerySyncingObject query a syncing object info by object id.

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

func (*Receiver) SyncObject

func (receiver *Receiver) SyncObject(stream types.ReceiverService_SyncObjectServer) (err error)

SyncObject an object payload to storage provider.

type ReceiverConfig

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