azure

Documentation

Index

• Constants
• func DeleteAzureBlob(accountURL, accountName, accountKey, containerName, remoteFile string, ...) error
• func DownloadAzureBlob(...) (types.DownloadedParts, error)
• func DownloadAzureBlobByChunks(...) (io.ReadCloser, int64, error)
• func GenerateBlobSasURI(accountURL, accountName, accountKey, containerName, remoteFile string, ...) (string, error)
• func GetAzureBlobMetaData(accountURL, accountName, accountKey, containerName, remoteFile string, ...) (int64, string, error)
• func ListAzureBlob(accountURL, accountName, accountKey, containerName string, ...) ([]string, error)
• func UploadAzureBlob(...) (string, error)
• func UploadBlockListToBlob(accountURL, accountName, accountKey, containerName, remoteFile string, ...) error
• func UploadPartByChunk(accountURL, accountName, accountKey, containerName, remoteFile, partID string, ...) error

Constants

const (
	// SingleMB contains chunk size
	SingleMB int64 = 1024 * 1024
)

Functions

func DeleteAzureBlob

func DeleteAzureBlob(accountURL, accountName, accountKey, containerName, remoteFile string, httpClient *http.Client) error

func DownloadAzureBlob

func DownloadAzureBlob(accountURL, accountName, accountKey, containerName, remoteFile, localFile string,
	objMaxSize int64, httpClient *http.Client, doneParts types.DownloadedParts, prgNotify types.StatsNotifChan) (types.DownloadedParts, error)

func DownloadAzureBlobByChunks

func DownloadAzureBlobByChunks(accountURL, accountName, accountKey, containerName, remoteFile, localFile string, httpClient *http.Client) (io.ReadCloser, int64, error)

DownloadAzureBlobByChunks will process the blob download by chunks, i.e., chunks will be responded back on as and when they receive

func GenerateBlobSasURI

func GenerateBlobSasURI(accountURL, accountName, accountKey, containerName, remoteFile string, httpClient *http.Client, duration time.Duration) (string, error)

GenerateBlobSasURI is used to generate the URI which can be used to access the blob until the the URI expries

func GetAzureBlobMetaData

func GetAzureBlobMetaData(accountURL, accountName, accountKey, containerName, remoteFile string, httpClient *http.Client) (int64, string, error)

func ListAzureBlob

func ListAzureBlob(accountURL, accountName, accountKey, containerName string, httpClient *http.Client) ([]string, error)

func UploadAzureBlob

func UploadAzureBlob(accountURL, accountName, accountKey, containerName, remoteFile, localFile string, httpClient *http.Client) (string, error)

func UploadBlockListToBlob

func UploadBlockListToBlob(accountURL, accountName, accountKey, containerName, remoteFile string, httpClient *http.Client, blocks []string) error

UploadBlockListToBlob used to complete the list of parts which are already uploaded in block blob

func UploadPartByChunk

func UploadPartByChunk(accountURL, accountName, accountKey, containerName, remoteFile, partID string, httpClient *http.Client, chunk io.ReadSeeker) error

UploadPartByChunk upload an individual chunk given an io.ReadSeeker and partID