azure

Documentation

Index

• type BlobStorage
  • func NewBlobStorage(cfg *BlobStorageConfig) *BlobStorage
  • func (b *BlobStorage) GetChunks(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error)
  • func (b *BlobStorage) PutChunks(ctx context.Context, chunks []chunk.Chunk) error
  • func (b *BlobStorage) Stop()
• type BlobStorageConfig
  • func (c *BlobStorageConfig) RegisterFlags(f *flag.FlagSet)

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

NewBlobStorage creates a new instance of the BlobStorage struct.

func (*BlobStorage) GetChunks

func (b *BlobStorage) GetChunks(ctx context.Context, chunks []chunk.Chunk) ([]chunk.Chunk, error)

GetChunks retrieves the requested data chunks from blob storage.

func (*BlobStorage) PutChunks

func (b *BlobStorage) PutChunks(ctx context.Context, chunks []chunk.Chunk) error

PutChunks writes a set of chunks to azure blob storage using block blobs.

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 {
	ContainerName      string        `yaml:"container_name"`
	AccountName        string        `yaml:"account_name"`
	AccountKey         string        `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