uploader

Documentation

Index

• type Uploader
  • func NewUploaderService(cfg *UploaderConfig) (*Uploader, error)
  • func (uploader *Uploader) Name() string
  • func (uploader *Uploader) PutObject(stream types.UploaderService_PutObjectServer) (err error)
  • func (uploader *Uploader) QueryPuttingObject(ctx context.Context, req *types.QueryPuttingObjectRequest) (resp *types.QueryPuttingObjectResponse, err error)
  • func (uploader *Uploader) QueryUploadProgress(ctx context.Context, req *types.QueryUploadProgressRequest) (resp *types.QueryUploadProgressResponse, err error)
  • func (uploader *Uploader) Start(ctx context.Context) error
  • func (uploader *Uploader) Stop(ctx context.Context) error
• type UploaderConfig

Types

type Uploader

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

Uploader implements the gRPC of UploaderService, responsible for uploading object payload data.

func NewUploaderService

func NewUploaderService(cfg *UploaderConfig) (*Uploader, error)

NewUploaderService returns an instance of Uploader that implementation of the lifecycle.Service and UploaderService interface

func (*Uploader) Name

func (uploader *Uploader) Name() string

Name return the uploader service name, for the lifecycle management

func (*Uploader) PutObject

func (uploader *Uploader) PutObject(stream types.UploaderService_PutObjectServer) (err error)

PutObject upload an object payload data with object info.

func (*Uploader) QueryPuttingObject

func (uploader *Uploader) QueryPuttingObject(ctx context.Context, req *types.QueryPuttingObjectRequest) (
	resp *types.QueryPuttingObjectResponse, err error)

QueryPuttingObject query an uploading object with object id from cache

func (*Uploader) QueryUploadProgress

func (uploader *Uploader) QueryUploadProgress(ctx context.Context, req *types.QueryUploadProgressRequest) (
	resp *types.QueryUploadProgressResponse, err error)

func (*Uploader) Start

func (uploader *Uploader) Start(ctx context.Context) error

Start the uploader gRPC service

func (*Uploader) Stop

func (uploader *Uploader) Stop(ctx context.Context) error

Stop the uploader gRPC service and recycle the resources

type UploaderConfig

type UploaderConfig struct {
	GRPCAddress         string
	SignerGrpcAddress   string
	TaskNodeGrpcAddress string
	SpDBConfig          *config.SQLDBConfig
	PieceStoreConfig    *storage.PieceStoreConfig
}

UploaderConfig defines Uploader service config