azure

Documentation

Index

• func DeleteBlob(containerClient *azblob.ContainerClient, blobName string, ...) error
• func DownloadFile(containerClient *azblob.ContainerClient, blobName, path string) error
• func IsAzureError(err error, code azblob.StorageErrorCode) bool
• func PutDirectory(containerClient *azblob.ContainerClient, blobName, path string) error
• func PutFile(containerClient *azblob.ContainerClient, blobName, path string) error
• type ArtifactDriver
  • func (azblobDriver *ArtifactDriver) Delete(artifact *wfv1.Artifact) error
  • func (azblobDriver *ArtifactDriver) DownloadDirectory(containerClient *azblob.ContainerClient, artifact *wfv1.Artifact, path string) error
  • func (azblobDriver *ArtifactDriver) IsDirectory(artifact *wfv1.Artifact) (bool, error)
  • func (azblobDriver *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)
  • func (azblobDriver *ArtifactDriver) Load(artifact *wfv1.Artifact, path string) error
  • func (azblobDriver *ArtifactDriver) OpenStream(artifact *wfv1.Artifact) (io.ReadCloser, error)
  • func (azblobDriver *ArtifactDriver) Save(path string, outputArtifact *wfv1.Artifact) error

Functions

func DeleteBlob

func DeleteBlob(containerClient *azblob.ContainerClient, blobName string, allowNonExistent bool) error

func DownloadFile

func DownloadFile(containerClient *azblob.ContainerClient, blobName, path string) error

DownloadFile downloads a single file from Azure Blob Storage

func IsAzureError

func IsAzureError(err error, code azblob.StorageErrorCode) bool

func PutDirectory

func PutDirectory(containerClient *azblob.ContainerClient, blobName, path string) error

PutDirectory uploads all files in a directory to Azure Blob Storage

func PutFile

func PutFile(containerClient *azblob.ContainerClient, blobName, path string) error

PutFile uploads a file to Azure Blob Storage

Types

type ArtifactDriver

type ArtifactDriver struct {
	AccountKey  string
	Container   string
	Endpoint    string
	UseSDKCreds bool
}

ArtifactDriver is a driver for Azure Blob Storage

func (*ArtifactDriver) Delete

func (azblobDriver *ArtifactDriver) Delete(artifact *wfv1.Artifact) error

Delete deletes an artifact from a Azure Blob Storage

func (*ArtifactDriver) DownloadDirectory

func (azblobDriver *ArtifactDriver) DownloadDirectory(containerClient *azblob.ContainerClient, artifact *wfv1.Artifact, path string) error

DownloadDirectory downloads all of the files starting with the named blob prefix into a local directory.

func (*ArtifactDriver) IsDirectory

func (azblobDriver *ArtifactDriver) IsDirectory(artifact *wfv1.Artifact) (bool, error)

IsDirectory indicates whether or not the artifact represents a directory or a single file.

func (*ArtifactDriver) ListObjects

func (azblobDriver *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)

ListObjects lists the files in Azure Blob Storage

func (*ArtifactDriver) Load

func (azblobDriver *ArtifactDriver) Load(artifact *wfv1.Artifact, path string) error

Load downloads artifacts from Azure Blob Storage

func (*ArtifactDriver) OpenStream

func (azblobDriver *ArtifactDriver) OpenStream(artifact *wfv1.Artifact) (io.ReadCloser, error)

OpenStream opens a stream reader for an artifact from Azure Blob Storage

func (*ArtifactDriver) Save

func (azblobDriver *ArtifactDriver) Save(path string, outputArtifact *wfv1.Artifact) error

Save saves an artifact to Azure Blob Storage