storage

package

v1.0.2 Latest Latest Go to latest Published: Jul 9, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func ConnectMinio(cfg *config.Env) (*minio.Client, error)

type Storage struct {
	MinioClient *minio.Client
	// contains filtered or unexported fields
}

func NewStorage(cfg *config.Env, minioClient *minio.Client) *Storage

func (pkg *Storage) BucketExists(bucketName string) (bool, error)

func (pkg *Storage) Close() error

func (pkg *Storage) CopyObject(srcBucket, srcObject, destBucket, destObject string) error

func (pkg *Storage) CreateBucket(bucketName string) error

func (pkg *Storage) DeleteObject(bucketName, objectName string) error

func (pkg *Storage) Download(bucketName, objectName, filePath string) error

func (pkg *Storage) GeneratePresignedPutURL(bucketName, objectName string, expiry time.Duration) (string, error)

func (pkg *Storage) GeneratePresignedURL(bucketName, objectName string, expiry time.Duration) (string, error)

func (pkg *Storage) GetBucketPolicy(bucketName string) (string, error)

func (pkg *Storage) GetObjectInfo(bucketName, objectName string) (minio.ObjectInfo, error)

func (pkg *Storage) ListObjects(bucketName, prefix string, recursive bool) <-chan minio.ObjectInfo

func (pkg *Storage) RemoveBucket(bucketName string) error

func (pkg *Storage) SafeDownload(bucketName, objectName, filePath string) error

func (pkg *Storage) SetBucketPolicy(bucketName, policy string) error

func (pkg *Storage) Upload(bucketName, objectPath, objectName string) (string, error)

func (pkg *Storage) UploadFromStream(bucketName, objectName string, reader io.Reader, size int64) error