blob_storage

Jun 21, 2023

Changes in this version

+ const BLOB_STORAGE_AZURE

+ const BLOB_STORAGE_GCP

+ const BLOB_STORAGE_MINIO

+ const BLOB_STORAGE_S3

+ type AwsS3BaseConfig struct

+ AccessKey string

+ BucketName string

+ EndpointUrl string

+ IsInSecure bool

+ Passkey string

+ Region string

+ VersioningEnabled bool

+ type AwsS3Blob struct

+ func (impl *AwsS3Blob) DeleteObjectFromBlob(request *BlobStorageRequest) error

+ func (impl *AwsS3Blob) DownloadBlob(request *BlobStorageRequest, downloadSuccess bool, numBytes int64, err error, ...) (bool, int64, error)

+ func (impl *AwsS3Blob) UploadBlob(request *BlobStorageRequest, err error) error

+ func (impl *AwsS3Blob) UploadWithSession(request *BlobStorageRequest) (*s3manager.UploadOutput, error)

+ type AzureBlob struct

+ func (impl *AzureBlob) DownloadBlob(context context.Context, blobName string, config *AzureBlobBaseConfig, ...) (success bool, err error)

+ func (impl *AzureBlob) UploadBlob(context context.Context, blobName string, config *AzureBlobBaseConfig, ...) error

+ type AzureBlobBaseConfig struct

+ AccountKey string

+ AccountName string

+ BlobContainerName string

+ Enabled bool

+ type AzureBlobConfig struct

+ AccountKey string

+ AccountName string

+ BlobContainerArtifact string

+ BlobContainerCiCache string

+ BlobContainerCiLog string

+ Enabled bool

+ type BlobStorageRequest struct

+ AwsS3BaseConfig *AwsS3BaseConfig

+ AzureBlobBaseConfig *AzureBlobBaseConfig

+ DestinationKey string

+ GcpBlobBaseConfig *GcpBlobBaseConfig

+ SourceKey string

+ StorageType BlobStorageType

+ type BlobStorageS3Config struct

+ AccessKey string

+ CiArtifactBucketName string

+ CiArtifactBucketVersioning bool

+ CiArtifactRegion string

+ CiCacheBucketName string

+ CiCacheBucketVersioning bool

+ CiCacheRegion string

+ CiLogBucketName string

+ CiLogBucketVersioning bool

+ CiLogRegion string

+ EndpointUrl string

+ IsInSecure bool

+ Passkey string

+ type BlobStorageService interface

+ DeleteObjectForS3 func(request *BlobStorageRequest) error

+ Get func(request *BlobStorageRequest) (bool, error)

+ PutWithCommand func(request *BlobStorageRequest) error

+ type BlobStorageServiceImpl struct

+ func NewBlobStorageServiceImpl(logger *zap.SugaredLogger) *BlobStorageServiceImpl

+ func (impl *BlobStorageServiceImpl) DeleteObjectForS3(request *BlobStorageRequest) error

+ func (impl *BlobStorageServiceImpl) Get(request *BlobStorageRequest) (bool, int64, error)

+ func (impl *BlobStorageServiceImpl) PutWithCommand(request *BlobStorageRequest) error

+ func (impl *BlobStorageServiceImpl) UploadToBlobWithSession(request *BlobStorageRequest) error

+ type BlobStorageType string

+ type GCPBlob struct

+ func (impl *GCPBlob) DownloadBlob(request *BlobStorageRequest, file *os.File) (bool, int64, error)

+ func (impl *GCPBlob) UploadBlob(request *BlobStorageRequest) error

+ type GcpBlobBaseConfig struct

+ BucketName string

+ CredentialFileJsonData string

+ type GcpBlobConfig struct

+ ArtifactBucketName string

+ CacheBucketName string

+ CredentialFileJsonData string

+ LogBucketName string