azure

package

v4.0.2 Latest Latest Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

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

Repository

github.com/argoproj/argo-workflows

Links

Open Source Insights

Documentation ¶

Index ¶

func DeleteBlob(ctx context.Context, containerClient *container.Client, blobName string, ...) error
func DownloadFile(ctx context.Context, containerClient *container.Client, blobName, path string) error
func PutDirectory(ctx context.Context, containerClient *container.Client, blobName, path string) error
func PutFile(ctx context.Context, containerClient *container.Client, blobName, path string) error
type ArtifactDriver

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeleteBlob ¶

func DeleteBlob(ctx context.Context, containerClient *container.Client, blobName string, allowNonExistent bool) error

func DownloadFile ¶

func DownloadFile(ctx context.Context, containerClient *container.Client, blobName, path string) error

DownloadFile downloads a single file from Azure Blob Storage

func PutDirectory ¶

func PutDirectory(ctx context.Context, containerClient *container.Client, blobName, path string) error

PutDirectory uploads all files in a directory to Azure Blob Storage

func PutFile ¶

func PutFile(ctx context.Context, containerClient *container.Client, 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(ctx context.Context, artifact *wfv1.Artifact) error

Delete deletes an artifact from a Azure Blob Storage

func (*ArtifactDriver) DownloadDirectory ¶

func (azblobDriver *ArtifactDriver) DownloadDirectory(ctx context.Context, containerClient *container.Client, 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(ctx context.Context, 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(ctx context.Context, artifact *wfv1.Artifact) ([]string, error)

ListObjects lists the files in Azure Blob Storage

func (*ArtifactDriver) Load ¶

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

Load downloads artifacts from Azure Blob Storage

func (*ArtifactDriver) OpenStream ¶

func (azblobDriver *ArtifactDriver) OpenStream(ctx context.Context, 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(ctx context.Context, path string, outputArtifact *wfv1.Artifact) error

Save saves an artifact to Azure Blob Storage

Source Files ¶

View all Source files

azure.go

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