uploader

Documentation

Index

• Constants
• Variables
• type ProgressConfig
  • func NewProgressConfig(progress *mpb.Progress, descriptor string) ProgressConfig
  • func (p *ProgressConfig) GetPrefix() string
• type Uploader
  • func NewS3Uploader(client *s3.Client) Uploader

Constants

const (
	UPLOADER_MAX_PARTS_UPLOAD_KEY        = "UPLOADER_MAX_PARTS_UPLOAD"
	UPLOADER_MULTIPART_SIZE_KEY          = "UPLOADER_MULTIPART_SIZE"
	UPLOADER_MAX_MPU_RETRIES_KEY         = "UPLOADER_MAX_MPU_RETRIES"
	UPLOADER_MAX_PART_UPLOAD_RETRIES_KEY = "UPLOADER_MAX_PART_UPLOAD_RETRIES"
)

Variables

var (
	ErrSkippedOperation = errors.New("skipped operation")
)

Types

type ProgressConfig

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

func NewProgressConfig

func NewProgressConfig(progress *mpb.Progress, descriptor string) ProgressConfig

func (*ProgressConfig) GetPrefix

func (p *ProgressConfig) GetPrefix() string

type Uploader

type Uploader interface {
	UploadObject(ctx context.Context, objectPath, bucket, key string, p ProgressConfig) error
}

func NewS3Uploader

func NewS3Uploader(client *s3.Client) Uploader