Versions in this module Expand all Collapse all v3 v3.0.1 Mar 21, 2022 v3.0.0 Mar 21, 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) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error) + func (b *BlobStorage) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (b *BlobStorage) Stop() + type BlobStorageConfig struct + AccountKey flagext.Secret + AccountName string + ContainerName string + DownloadBufferSize int + Environment string + MaxRetries int + MaxRetryDelay time.Duration + MinRetryDelay time.Duration + RequestTimeout time.Duration + UploadBufferCount int + UploadBufferSize int + UseManagedIdentity bool + 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() Other modules containing this package github.com/pao214/loki/v2
Go to main page