oss

Documentation

Index

• func GetOssDirectory(bucket *oss.Bucket, objectName, path string) error
• func IsOssDirectory(bucket *oss.Bucket, objectName string) (bool, error)
• func IsOssErrCode(err error, code string) bool
• func ListOssDirectory(bucket *oss.Bucket, objectKey string) (files []string, err error)
• type ArtifactDriver
  • func (ossDriver *ArtifactDriver) Delete(s *wfv1.Artifact) error
  • func (g *ArtifactDriver) IsDirectory(artifact *wfv1.Artifact) (bool, error)
  • func (ossDriver *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)
  • func (ossDriver *ArtifactDriver) Load(inputArtifact *wfv1.Artifact, path string) error
  • func (ossDriver *ArtifactDriver) OpenStream(a *wfv1.Artifact) (io.ReadCloser, error)
  • func (ossDriver *ArtifactDriver) Save(path string, outputArtifact *wfv1.Artifact) error

Functions

func GetOssDirectory

func GetOssDirectory(bucket *oss.Bucket, objectName, path string) error

GetOssDirectory download an OSS "directory" to local path

func IsOssDirectory

func IsOssDirectory(bucket *oss.Bucket, objectName string) (bool, error)

IsOssDirectory tests if the key is acting like a OSS directory. This just means it has at least one object which is prefixed with the given key

func IsOssErrCode

func IsOssErrCode(err error, code string) bool

IsOssErrCode tests if an err is an oss.ServiceError with the specified code

func ListOssDirectory

func ListOssDirectory(bucket *oss.Bucket, objectKey string) (files []string, err error)

ListOssDirectory lists all the files which are the descendants of the specified objectKey, if a file has suffix '/', then it is an OSS directory

Types

type ArtifactDriver

type ArtifactDriver struct {
	Endpoint      string
	AccessKey     string
	SecretKey     string
	SecurityToken string
	UseSDKCreds   bool
}

ArtifactDriver is a driver for OSS

func (*ArtifactDriver) Delete

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

Delete is unsupported for the oss artifacts

func (*ArtifactDriver) IsDirectory

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

func (*ArtifactDriver) ListObjects

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

func (*ArtifactDriver) Load

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

Load downloads artifacts from OSS compliant storage, e.g., downloading an artifact into local path

func (*ArtifactDriver) OpenStream

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

func (*ArtifactDriver) Save

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

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