oss

package

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

Details

This section is empty.

This section is empty.

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

GetOssDirectory download an OSS "directory" to local path

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(err error, code string) bool

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

func ListOssDirectory(ctx context.Context, 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

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

ArtifactDriver is a driver for OSS

func (ossDriver *ArtifactDriver) Delete(ctx context.Context, artifact *wfv1.Artifact) error

Delete deletes an artifact from an OSS compliant storage

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

IsDirectory tests if the key is acting like a OSS directory

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

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

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

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

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

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

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