blobstorage

package

v1.11.0-rc.3 Latest Latest Go to latest Published: May 15, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/components-contrib

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateBlobHTTPHeadersFromRequest(meta map[string]string, contentType *string, log logger.Logger) (blob.HTTPHeaders, error)
func SanitizeMetadata(log logger.Logger, metadata map[string]string) map[string]*string
type BlobStorageMetadata
- func CreateContainerStorageClient(parentCtx context.Context, log logger.Logger, meta map[string]string) (*container.Client, *BlobStorageMetadata, error)
type ContainerClientOpts

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateBlobHTTPHeadersFromRequest ¶

func CreateBlobHTTPHeadersFromRequest(meta map[string]string, contentType *string, log logger.Logger) (blob.HTTPHeaders, error)

func SanitizeMetadata ¶

func SanitizeMetadata(log logger.Logger, metadata map[string]string) map[string]*string

SanitizeMetadata is used by Azure Blob Storage components to sanitize the metadata. Keys can only contain [A-Za-z0-9], and values are only allowed characters in the ASCII table.

Types ¶

type BlobStorageMetadata ¶

type BlobStorageMetadata struct {
	ContainerClientOpts `json:",inline" mapstructure:",squash"`
	DecodeBase64        bool `json:"decodeBase64,string"`
	PublicAccessLevel   azblob.PublicAccessType
}

func CreateContainerStorageClient ¶

func CreateContainerStorageClient(parentCtx context.Context, log logger.Logger, meta map[string]string) (*container.Client, *BlobStorageMetadata, error)

CreateContainerStorageClient returns a container.Client and the parsed metadata from the metadata dictionary.

type ContainerClientOpts ¶ added in v1.11.0

type ContainerClientOpts struct {
	// Use a connection string
	ConnectionString string
	ContainerName    string

	// Use a shared account key
	AccountName string
	AccountKey  string

	// Misc
	RetryCount int32 `json:"retryCount,string"`
	// contains filtered or unexported fields
}

func (ContainerClientOpts) EnsureContainer ¶ added in v1.11.0

func (opts ContainerClientOpts) EnsureContainer(ctx context.Context, client *container.Client, accessLevel *azblob.PublicAccessType) error

EnsureContainer creates the container if it doesn't already exist. Property "accessLevel" indicates the public access level; nil-value means the container is private

func (ContainerClientOpts) GetContainerURL ¶ added in v1.11.0

func (opts ContainerClientOpts) GetContainerURL(azEnvSettings azauth.EnvironmentSettings) (u *url.URL, err error)

GetContainerURL returns the URL of the container, needed by some auth methods.

func (ContainerClientOpts) InitContainerClient ¶ added in v1.11.0

func (opts ContainerClientOpts) InitContainerClient(azEnvSettings azauth.EnvironmentSettings) (client *container.Client, err error)

InitContainerClient returns a new container.Client object from the given options.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL