Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + type BlobStorage struct + func NewBlobStorage(cfg *BlobStorageConfig, metrics BlobStorageMetrics, hedgingCfg hedging.Config) (*BlobStorage, error) + func (b *BlobStorage) DeleteObject(ctx context.Context, blobID string) error + func (b *BlobStorage) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error) + func (b *BlobStorage) IsObjectNotFoundErr(err error) bool + func (b *BlobStorage) IsRetryableErr(error) bool + func (b *BlobStorage) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error) + func (b *BlobStorage) ObjectExists(ctx context.Context, objectKey string) (bool, error) + func (b *BlobStorage) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (b *BlobStorage) Stop() + type BlobStorageConfig struct + ChunkDelimiter string + ClientID string + ClientSecret flagext.Secret + ConnectionString string + ContainerName string + DownloadBufferSize int + EndpointSuffix string + Environment string + MaxRetries int + MaxRetryDelay time.Duration + MinRetryDelay time.Duration + RequestTimeout time.Duration + StorageAccountKey flagext.Secret + StorageAccountName string + TenantID string + UploadBufferCount int + UploadBufferSize int + UseFederatedToken bool + UseManagedIdentity bool + UseServicePrincipal bool + UserAssignedID string + func (c *BlobStorageConfig) RegisterFlags(f *flag.FlagSet) + func (c *BlobStorageConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (c *BlobStorageConfig) Validate() error + type BlobStorageMetrics struct + func NewBlobStorageMetrics() BlobStorageMetrics + func (bm *BlobStorageMetrics) Unregister() + type ParsedConnectionString struct + AccountKey string + AccountName string + ServiceURL string