s3

Documentation

Index

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

Types

type ArtifactDriver

type ArtifactDriver struct {
	Endpoint              string
	Region                string
	Secure                bool
	TrustedCA             string
	AccessKey             string
	SecretKey             string
	SessionToken          string
	RoleARN               string
	UseSDKCreds           bool
	Context               context.Context
	KmsKeyId              string
	KmsEncryptionContext  string
	EnableEncryption      bool
	ServerSideCustomerKey string
}

ArtifactDriver is a driver for AWS S3

func (*ArtifactDriver) Delete

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

Delete deletes an artifact from an S3 compliant storage

func (*ArtifactDriver) IsDirectory

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

func (*ArtifactDriver) ListObjects

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

ListObjects returns the files inside the directory represented by the Artifact

func (*ArtifactDriver) Load

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

Load downloads artifacts from S3 compliant storage

func (*ArtifactDriver) OpenStream

func (s3Driver *ArtifactDriver) OpenStream(inputArtifact *wfv1.Artifact) (io.ReadCloser, error)

OpenStream opens a stream reader for an artifact from S3 compliant storage

func (*ArtifactDriver) Save

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

Save saves an artifact to S3 compliant storage