storage

Jun 7, 2024

Changes in this version

type AwsS3

+ Endpoint string

+ S3ForcePathStyle bool

type AzBlob

+ Endpoint string

Dec 6, 2023

Changes in this version

type AwsS3

+ func (this *AwsS3) DeleteOldObjects() error

type AzBlob

+ func (this *AzBlob) DeleteOldObjects() error

type GcpStorage

+ func (this *GcpStorage) DeleteOldObjects() error

type LocalStorage

+ ExpiryDays int

+ func (this *LocalStorage) DeleteOldObjects() error

type Storage

+ DeleteOldObjects func() error

Nov 27, 2023

Changes in this version

+ type LocalStorage struct

+ LocalPath string

+ func (this *LocalStorage) Download(objectName string, filePath string) error

+ func (this *LocalStorage) GetTargetObjectName(objectName string) (string, error)

+ func (this *LocalStorage) Init(localPath string) error

+ func (this *LocalStorage) Upload(objectName string, buffer []byte) (string, error)

Jul 9, 2023

Changes in this version

+ type AwsS3 struct

+ AccessKeyId string

+ Bucket string

+ Region string

+ SecretAccessKey string

+ Service *s3.S3

+ Session *session.Session

+ func (this *AwsS3) Download(objectName string, filePath string) error

+ func (this *AwsS3) GetTargetObjectName(objectKey string) (string, error)

+ func (this *AwsS3) Init(accessKeyId string, secretAccessKey string, region string, bucket string) error

+ func (this *AwsS3) Upload(blobName string, buffer []byte) (string, error)

+ type AzBlob struct

+ AccountKey string

+ AccountName string

+ BlobContainerClient *container.Client

+ BlobServiceClient *azblob.Client

+ ContainerName string

+ func (this *AzBlob) Download(blobName string, filePath string) error

+ func (this *AzBlob) GetTargetObjectName(blobName string) (string, error)

+ func (this *AzBlob) Init(accountName string, accountKey string, containerName string) error

+ func (this *AzBlob) Upload(blobName string, buffer []byte) (string, error)

+ type GcpServiceAccountCreds struct

+ AuthProviderX509CertUrl string

+ AuthUri string

+ ClientEmail string

+ ClientID string

+ PrivateKey string

+ PrivateKeyID string

+ ProjectID string

+ TokenUri string

+ Type string

+ UniverseDomain string

+ type GcpStorage struct

+ Bucket string

+ StorageClient *storage.Client

+ func (this *GcpStorage) Close()

+ func (this *GcpStorage) Download(objectName string, filePath string) error

+ func (this *GcpStorage) GetTargetObjectName(objectName string) (string, error)

+ func (this *GcpStorage) Init(...) error

+ func (this *GcpStorage) Upload(objectName string, buffer []byte) (string, error)

+ type Storage interface

+ Download func(string, string) error

+ GetTargetObjectName func(string) (string, error)

+ Upload func(string, []byte) (string, error)