gcs

func (*ArtifactDriver) Delete ¶

func (h *ArtifactDriver) Delete(ctx context.Context, s *wfv1.Artifact) error

Delete deletes an artifact from GCS

func (*ArtifactDriver) IsDirectory ¶

func (h *ArtifactDriver) IsDirectory(ctx context.Context, artifact *wfv1.Artifact) (bool, error)

func (*ArtifactDriver) ListObjects ¶

func (h *ArtifactDriver) ListObjects(ctx context.Context, artifact *wfv1.Artifact) ([]string, error)

func (*ArtifactDriver) Load ¶

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

Load function downloads objects from GCS

func (*ArtifactDriver) OpenStream ¶

func (h *ArtifactDriver) OpenStream(ctx context.Context, a *wfv1.Artifact) (io.ReadCloser, error)

func (*ArtifactDriver) Save ¶

func (h *ArtifactDriver) Save(ctx context.Context, path string, outputArtifact *wfv1.Artifact) error

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