storage

Documentation

Index

• Variables
• func NewBlobSdkClient(credentialProvider auth.MultiTenantCredentialProvider, ...) (*azblob.Client, error)
• type AccountConfig
• type Blob
• type BlobClient
  • func NewBlobClient(config *AccountConfig, client *azblob.Client) BlobClient
• type FileShareService
  • func NewFileShareService(accountCreds account.SubscriptionCredentialProvider, ...) FileShareService

Variables

var (
	ErrContainerNotFound = errors.New("container not found")
)

Functions

func NewBlobSdkClient

func NewBlobSdkClient(
	credentialProvider auth.MultiTenantCredentialProvider,
	accountConfig *AccountConfig,
	coreClientOptions *azcore.ClientOptions,
	cloud *cloud.Cloud,
) (*azblob.Client, error)

createClient creates a new blob client and caches it for future use

Types

type AccountConfig

type AccountConfig struct {
	AccountName   string
	ContainerName string
	Endpoint      string
}

AccountConfig contains the configuration for connecting to a storage account

type Blob

type Blob struct {
	Name         string
	Path         string
	CreationTime time.Time
	LastModified time.Time
}

Blob represents a blob within a storage account container.

type BlobClient

type BlobClient interface {
	// Download downloads a blob from the configured storage account container.
	Download(ctx context.Context, blobPath string) (io.ReadCloser, error)

	// Upload uploads a blob to the configured storage account container.
	Upload(ctx context.Context, blobPath string, reader io.Reader) error

	// Delete deletes a blob from the configured storage account container.
	Delete(ctx context.Context, blobPath string) error

	// Items returns a list of blobs in the configured storage account container.
	Items(ctx context.Context) ([]*Blob, error)
}

func NewBlobClient

func NewBlobClient(
	config *AccountConfig,
	client *azblob.Client,
) BlobClient

NewBlobClient creates a new BlobClient instance to manage blobs within a container.

type FileShareService

type FileShareService interface {
	// Upload files from source path to a file share
	UploadPath(ctx context.Context, subId, shareUrl, source string) error
}

func NewFileShareService

func NewFileShareService(
	accountCreds account.SubscriptionCredentialProvider,
	options *arm.ClientOptions,
) FileShareService