gcs

Documentation

Index

• type ArtifactDriver
  • func (h *ArtifactDriver) Delete(s *wfv1.Artifact) error
  • func (g *ArtifactDriver) IsDirectory(artifact *wfv1.Artifact) (bool, error)
  • func (g *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)
  • func (g *ArtifactDriver) Load(inputArtifact *wfv1.Artifact, path string) error
  • func (g *ArtifactDriver) OpenStream(a *wfv1.Artifact) (io.ReadCloser, error)
  • func (g *ArtifactDriver) Save(path string, outputArtifact *wfv1.Artifact) error

Types

type ArtifactDriver

type ArtifactDriver struct {
	ServiceAccountKey string
}

ArtifactDriver is a driver for GCS

func (*ArtifactDriver) Delete

func (h *ArtifactDriver) Delete(s *wfv1.Artifact) error

Delete deletes an artifact from GCS

func (*ArtifactDriver) IsDirectory

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

func (*ArtifactDriver) ListObjects

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

func (*ArtifactDriver) Load

func (g *ArtifactDriver) Load(inputArtifact *wfv1.Artifact, path string) error

Load function downloads objects from GCS

func (*ArtifactDriver) OpenStream

func (g *ArtifactDriver) OpenStream(a *wfv1.Artifact) (io.ReadCloser, error)

func (*ArtifactDriver) Save

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

Save an artifact to GCS compliant storage, e.g., uploading a local file to GCS bucket