Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 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) List(ctx context.Context, prefix, delimiter string) ([]client.StorageObject, []client.StorageCommonPrefix, error) + func (b *BlobStorage) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (b *BlobStorage) Stop() + type BlobStorageConfig struct + ChunkDelimiter string + ContainerName string + DownloadBufferSize int + Endpoint string + Environment string + MaxRetries int + MaxRetryDelay time.Duration + MinRetryDelay time.Duration + RequestTimeout time.Duration + StorageAccountKey flagext.Secret + StorageAccountName string + UploadBufferCount int + UploadBufferSize int + UseManagedIdentity 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()
Go to main page