uploader

Documentation

Index

• Variables
• func NewCacheUploader(uploader contracts.Uploader, cache func() contracts.CacheInterface) contracts.Uploader
• func NewFileInfo[T uint64 | int64 | int](path string, size T, lastModified time.Time) *fileInfo
• func NewS3(client *minio.Client, bucket string, uploader contracts.Uploader, ...) contracts.Uploader
• func NewUploader(rootDir string, disk string) (contracts.Uploader, error)

Variables

var DefaultRootDir = "/tmp/mars-uploads"

var DirSizeCacheSeconds = int((15 * time.Minute).Seconds())

Functions

func NewCacheUploader

func NewCacheUploader(uploader contracts.Uploader, cache func() contracts.CacheInterface) contracts.Uploader

func NewFileInfo

func NewFileInfo[T uint64 | int64 | int](path string, size T, lastModified time.Time) *fileInfo

func NewS3

func NewS3(client *minio.Client, bucket string, uploader contracts.Uploader, rootDir string) contracts.Uploader

NewS3 rootDir 必须要，不然在 DeleteDir 的时候如果传空会报错

func NewUploader

func NewUploader(rootDir string, disk string) (contracts.Uploader, error)