azure

Documentation

Index

• func CreateContainer(ctx context.Context, conf *Config) (blob.ContainerURL, error)
• func GetBlobURL(ctx context.Context, conf *Config, blobName string) (blob.BlockBlobURL, error)
• func GetContainer(ctx context.Context, conf *Config, hedge bool) (blob.ContainerURL, error)
• func GetContainerURL(ctx context.Context, cfg *Config, hedge bool) (blob.ContainerURL, error)
• func New(cfg *Config) (backend.RawReader, backend.RawWriter, backend.Compactor, error)
• func NewNoConfirm(cfg *Config) (backend.RawReader, backend.RawWriter, backend.Compactor, error)
• type BlobAttributes
• type Config

Functions

func CreateContainer

func CreateContainer(ctx context.Context, conf *Config) (blob.ContainerURL, error)

func GetBlobURL

func GetBlobURL(ctx context.Context, conf *Config, blobName string) (blob.BlockBlobURL, error)

func GetContainer

func GetContainer(ctx context.Context, conf *Config, hedge bool) (blob.ContainerURL, error)

func GetContainerURL

func GetContainerURL(ctx context.Context, cfg *Config, hedge bool) (blob.ContainerURL, error)

func New

func New(cfg *Config) (backend.RawReader, backend.RawWriter, backend.Compactor, error)

New gets the Azure blob container

func NewNoConfirm

func NewNoConfirm(cfg *Config) (backend.RawReader, backend.RawWriter, backend.Compactor, error)

NewNoConfirm gets the Azure blob container without testing it

Types

type BlobAttributes

type BlobAttributes struct {
	// Size is the blob size in bytes.
	Size int64 `json:"size"`

	// LastModified is the timestamp the blob was last modified.
	LastModified time.Time `json:"last_modified"`
}

type Config

type Config struct {
	StorageAccountName string         `yaml:"storage-account-name"`
	StorageAccountKey  flagext.Secret `yaml:"storage-account-key"`
	UseManagedIdentity bool           `yaml:"use-managed-identity"`
	UserAssignedID     string         `yaml:"user-assigned-id"`
	ContainerName      string         `yaml:"container-name"`
	Endpoint           string         `yaml:"endpoint-suffix"`
	MaxBuffers         int            `yaml:"max-buffers"`
	BufferSize         int            `yaml:"buffer-size"`
	HedgeRequestsAt    time.Duration  `yaml:"hedge-requests-at"`
	HedgeRequestsUpTo  int            `yaml:"hedge-requests-up-to"`
}