upload

Documentation

Index

• Constants
• Variables
• func WithCertify(ct *certify.Certify) func(manager *uploadManager)
• func WithLimiter(limiter *rate.Limiter) func(*uploadManager)
• type DownloadParams
• type DownloadQuery
• type Manager
  • func NewUploadManager(cfg *config.DaemonOption, storageManager storage.Manager, logDir string, ...) (Manager, error)
• type Option

Constants

const (
	PrometheusSubsystemName = "dragonfly_dfdaemon_upload"
	OtelServiceName         = "dragonfly-dfdaemon-upload"
)

const (
	RouterGroupDownload = "/download"
)

Variables

var GinLogFileName = "gin-upload.log"

Functions

func WithCertify

func WithCertify(ct *certify.Certify) func(manager *uploadManager)

func WithLimiter

func WithLimiter(limiter *rate.Limiter) func(*uploadManager)

WithLimiter sets upload rate limiter, the burst size must be bigger than piece size.

Types

type DownloadParams

type DownloadParams struct {
	TaskPrefix string `uri:"task_prefix" binding:"required"`
	TaskID     string `uri:"task_id" binding:"required"`
}

type DownloadQuery

type DownloadQuery struct {
	PeerID string `form:"peerId" binding:"required"`
}

type Manager

type Manager interface {
	// Started upload manager server.
	Serve(lis net.Listener) error

	// Stop upload manager server.
	Stop() error
}

Manager is the interface used for upload task.

func NewUploadManager

func NewUploadManager(cfg *config.DaemonOption, storageManager storage.Manager, logDir string, opts ...Option) (Manager, error)

New returns a new Manager instance.

type Option

type Option func(um *uploadManager)

Option is a functional option for configuring the upload manager.