diff --git a/internal/objstorage/minio.go b/internal/objstorage/minio.go index 3400c8f8a..cbe6a699f 100644 --- a/internal/objstorage/minio.go +++ b/internal/objstorage/minio.go @@ -9,9 +9,9 @@ import ( "time" ) -//func NewMinio() Interface { -// return &minioImpl{} -//} +func NewMinio() Interface { + return &minioImpl{} +} type minioImpl struct { uploadBucket string // 上传桶 @@ -36,6 +36,10 @@ func (m *minioImpl) Name() string { return "minio" } +func (m *minioImpl) MinMultipartSize() int64 { + return 1024 * 1024 * 5 // minio.absMinPartSize +} + func (m *minioImpl) UploadBucket() string { return m.uploadBucket } diff --git a/internal/objstorage/oo.go b/internal/objstorage/oo.go index 33a0eb5b5..b9b365ccb 100644 --- a/internal/objstorage/oo.go +++ b/internal/objstorage/oo.go @@ -5,6 +5,7 @@ import "context" type Interface interface { Init() error Name() string + MinMultipartSize() int64 UploadBucket() string PermanentBucket() string ClearBucket() string diff --git a/pkg/utils/utils_v2.go b/pkg/utils/utils_v2.go index 38fae8424..8d567e050 100644 --- a/pkg/utils/utils_v2.go +++ b/pkg/utils/utils_v2.go @@ -32,6 +32,11 @@ func SliceSubAny[E comparable, T any](a []E, b []T, fn func(t T) E) []E { return SliceSub(a, Slice(b, fn)) } +// SliceAnySub a中存在,b中不存在 (a-b) fn 返回的是uuid +func SliceAnySub[E any, T comparable](a, b []E, fn func(t E) T) []E { + panic("todo") +} + // DistinctAny 去重 func DistinctAny[E any, K comparable](es []E, fn func(e E) K) []E { v := make([]E, 0, len(es))