object_storage

Jul 28, 2025

Changes in this version

type AWSObjectStorageService

+ func (service *AWSObjectStorageService) CopyObject(ctx context.Context, from, to string) error

type AliCloudObjectStorageService

+ func (service *AliCloudObjectStorageService) CopyObject(ctx context.Context, from, to string) error

type ObjectStorageService

+ CopyObject func(ctx context.Context, from, to string) error

type TencentCloudObjectStorageService

+ func (service *TencentCloudObjectStorageService) CopyObject(ctx context.Context, from, to string) error

Dec 17, 2024

Changes in this version

+ type COSOption cloud.CommonCloudOption

+ func (option COSOption) Check() error

+ type ObjectStorageOption struct

+ Bucket string

+ COS COSOption

+ OSS AliCloudStorageOption

+ Path string

+ Provider cloud.Provider

+ S3 cloud.AWSOption

+ func (option ObjectStorageOption) Check() error

type ObjectStorageService

+ func GetObjectStorageServiceWithOption(option ObjectStorageOption) (ObjectStorageService, error)

Sep 2, 2024

Changes in this version

+ var ErrAliCloudStorageServiceAccessKeyIDEmpty = errors.New("access_key_id for alicloud storage service is empty")

+ var ErrAliCloudStorageServiceAccessKeySecretEmpty = errors.New("access_key_secret for alicloud storage service is empty")

type AWSObjectStorageService

+ func (service *AWSObjectStorageService) PutSignedURL(key string, duration time.Duration, option PutHeaderOption) (string, error)

type AliCloudObjectStorageService

+ func (service *AliCloudObjectStorageService) PutSignedURL(key string, duration time.Duration, option PutHeaderOption) (string, error)

type AliCloudStorageOption

+ AccessKeyID string

+ AccessKeySecret string

type ObjectStorageService

+ PutSignedURL func(key string, duration time.Duration, option PutHeaderOption) (string, error)

+ type PutHeaderOption struct

+ ContentDisposition *string

+ ContentEncoding *string

+ ContentLength *int64

+ ContentMD5 *string

+ ContentType *string

+ Tagging *string

+ func (o *PutHeaderOption) ToAliCloudOptions() []oss.Option

+ func (o *PutHeaderOption) ToTencentCloudOptions() *cos.PresignedURLOptions

type TencentCloudObjectStorageService

+ func (service *TencentCloudObjectStorageService) PutSignedURL(key string, duration time.Duration, option PutHeaderOption) (string, error)

Feb 27, 2024

Changes in this version

type PutObjectInput

+ Tagging string

Oct 26, 2023

Changes in this version

+ const AliCloudEnvOidcProviderArn

+ const AliCloudEnvOidcTokenFile

+ const AliCloudEnvRoleArn

+ var ErrAliCloudStorageServiceCredentialTypeEmpty = errors.New("credential_type for alicloud storage service is empty")

+ var ErrAliCloudStorageServiceEndPointEmpty = errors.New("endpoint for alicloud storage service is empty")

+ var ErrAliCloudStorageServiceSessionNameEmpty = errors.New("session_name for alicloud storage service is empty")

+ func HTTPHeaderLastModifiedToTime(timeStr string) (time.Time, error)

+ type AliCloudObjectStorageService struct

+ func (service *AliCloudObjectStorageService) DeleteObject(ctx context.Context, key string) error

+ func (service *AliCloudObjectStorageService) DeleteObjects(ctx context.Context, keys ...string) error

+ func (service *AliCloudObjectStorageService) GetObject(ctx context.Context, key string) (Object, error)

+ func (service *AliCloudObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error)

+ func (service *AliCloudObjectStorageService) GetSignedURLForExistedKey(ctx context.Context, key string, duration time.Duration) (string, error)

+ func (service *AliCloudObjectStorageService) HeadObject(ctx context.Context, key string) (Object, error)

+ func (service *AliCloudObjectStorageService) ListObjects(ctx context.Context, prefix string, continueToken *string, maxObjects int) ([]Object, *string, error)

+ func (service *AliCloudObjectStorageService) PutObject(ctx context.Context, key string, input *PutObjectInput) error

+ type AliCloudStorageOption struct

+ CredentialType string

+ EndPoint string

+ SessionName string

+ func (option AliCloudStorageOption) CheckAWS() error

+ func (option AliCloudStorageOption) CheckAliCloudStorage() error

+ func (option AliCloudStorageOption) CheckClusterRedis() error

+ func (option AliCloudStorageOption) CheckStandaloneRedis() error

+ func (option AliCloudStorageOption) CheckTencentCloud() error

+ func (option AliCloudStorageOption) GetAssumeRegion() string

+ func (option AliCloudStorageOption) GetAssumeRoleArn() string

+ func (option AliCloudStorageOption) GetProvider() cloud.Provider

+ func (option AliCloudStorageOption) GetRegion() string

+ func (option AliCloudStorageOption) GetSecretID() string

+ func (option AliCloudStorageOption) GetSecretKey() string

type ObjectStorageService

+ func GetAliCloudObjectService(bucketName string, option cloud.Option) (ObjectStorageService, error)

Nov 12, 2021

Changes in this version

type Object

+ func (object Object) GetContentType() string

+ type PutObjectInput struct

+ Body []byte

+ ContentType string

Nov 10, 2021

Changes in this version

+ var ErrObjectNotFound = errors.New("object is not found")

type AWSObjectStorageService

+ func (service *AWSObjectStorageService) GetSignedURLForExistedKey(ctx context.Context, key string, duration time.Duration) (string, error)

+ func (service *AWSObjectStorageService) HeadObject(ctx context.Context, key string) (Object, error)

type Object

+ func (object Object) GetObjectSize() int64

type ObjectStorageService

+ GetSignedURLForExistedKey func(ctx context.Context, key string, duration time.Duration) (string, error)

+ HeadObject func(ctx context.Context, key string) (Object, error)

type TencentCloudObjectStorageService

+ func (service *TencentCloudObjectStorageService) GetSignedURLForExistedKey(ctx context.Context, key string, duration time.Duration) (string, error)

+ func (service *TencentCloudObjectStorageService) HeadObject(ctx context.Context, key string) (Object, error)

Nov 5, 2021

Changes in this version

+ var ErrBucketNameEmpty = errors.New("bucket name is empty")

+ var ErrObjectKeyEmpty = errors.New("object key is empty")

+ type AWSObjectStorageService struct

+ func (service *AWSObjectStorageService) DeleteObject(ctx context.Context, key string) error

+ func (service *AWSObjectStorageService) DeleteObjects(ctx context.Context, keys ...string) error

+ func (service *AWSObjectStorageService) GetObject(ctx context.Context, key string) (*Object, error)

+ func (service *AWSObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error)

+ func (service *AWSObjectStorageService) ListObjects(ctx context.Context, prefix string, continueToken *string, maxObjects int) ([]*Object, *string, error)

+ func (service *AWSObjectStorageService) PutObject(ctx context.Context, key string, body []byte) error

+ type Object struct

+ func (object Object) GetContent() ([]byte, error)

+ func (object Object) GetKey() string

+ func (object Object) GetModifiedTime() time.Time

+ type ObjectStorageService interface

+ DeleteObject func(ctx context.Context, key string) error

+ DeleteObjects func(ctx context.Context, keys ...string) error

+ GetObject func(ctx context.Context, key string) (*Object, error)

+ GetSignedURL func(key string, duration time.Duration) (string, error)

+ ListObjects func(ctx context.Context, prefix string, continueToken *string, maxObjects int) ([]*Object, *string, error)

+ PutObject func(ctx context.Context, key string, body []byte) error

+ func GetAWSObjectService(bucketName string, option cloud.Option) (ObjectStorageService, error)

+ func GetObjectStorageService(bucketName string, option cloud.Option) (ObjectStorageService, error)

+ func GetTencentCloudObjectService(bucketName string, option cloud.Option) (ObjectStorageService, error)

+ type TencentCloudObjectStorageService struct

+ func (service *TencentCloudObjectStorageService) DeleteObject(ctx context.Context, key string) error

+ func (service *TencentCloudObjectStorageService) DeleteObjects(ctx context.Context, keys ...string) error

+ func (service *TencentCloudObjectStorageService) GetObject(ctx context.Context, key string) (*Object, error)

+ func (service *TencentCloudObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error)

+ func (service *TencentCloudObjectStorageService) ListObjects(ctx context.Context, prefix string, continueToken *string, maxObjects int) ([]*Object, *string, error)

+ func (service *TencentCloudObjectStorageService) PutObject(ctx context.Context, key string, body []byte) error