azure

Documentation

Index

• type BlobStorage
  • func NewBlobStorage(cfg *BlobStorageConfig) (*BlobStorage, error)
  • func (b *BlobStorage) DeleteObject(ctx context.Context, blobID string) error
  • func (b *BlobStorage) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)
  • 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
  • func (c *BlobStorageConfig) RegisterFlags(f *flag.FlagSet)
  • func (c *BlobStorageConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
  • func (c *BlobStorageConfig) Validate() error

Types

type BlobStorage

type BlobStorage struct {
	// contains filtered or unexported fields
}

BlobStorage is used to interact with azure blob storage for setting or getting time series chunks. Implements ObjectStorage

func NewBlobStorage

func NewBlobStorage(cfg *BlobStorageConfig) (*BlobStorage, error)

NewBlobStorage creates a new instance of the BlobStorage struct.

func (*BlobStorage) DeleteObject

func (b *BlobStorage) DeleteObject(ctx context.Context, blobID string) error

func (*BlobStorage) GetObject

func (b *BlobStorage) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, error)

func (*BlobStorage) List

func (b *BlobStorage) List(ctx context.Context, prefix, delimiter string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error)

List implements chunk.ObjectClient.

func (*BlobStorage) PutObject

func (b *BlobStorage) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error

func (*BlobStorage) Stop

func (b *BlobStorage) Stop()

Stop is a no op, as there are no background workers with this driver currently

type BlobStorageConfig

type BlobStorageConfig struct {
	Environment        string         `yaml:"environment"`
	ContainerName      string         `yaml:"container_name"`
	AccountName        string         `yaml:"account_name"`
	AccountKey         flagext.Secret `yaml:"account_key"`
	DownloadBufferSize int            `yaml:"download_buffer_size"`
	UploadBufferSize   int            `yaml:"upload_buffer_size"`
	UploadBufferCount  int            `yaml:"upload_buffer_count"`
	RequestTimeout     time.Duration  `yaml:"request_timeout"`
	MaxRetries         int            `yaml:"max_retries"`
	MinRetryDelay      time.Duration  `yaml:"min_retry_delay"`
	MaxRetryDelay      time.Duration  `yaml:"max_retry_delay"`
}

BlobStorageConfig defines the configurable flags that can be defined when using azure blob storage.

func (*BlobStorageConfig) RegisterFlags

func (c *BlobStorageConfig) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

func (*BlobStorageConfig) RegisterFlagsWithPrefix

func (c *BlobStorageConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix adds the flags required to config this to the given FlagSet

func (*BlobStorageConfig) Validate

func (c *BlobStorageConfig) Validate() error

Validate the config.