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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetOssDirectory ¶ added in v3.2.0
GetOssDirectory download an OSS "directory" to local path
func IsOssDirectory ¶ added in v3.2.0
IsDirectory 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 ¶ added in v3.2.0
IsOssErrCode tests if an err is an oss.ServiceError with the specified code
Types ¶
type ArtifactDriver ¶ added in v3.1.0
type ArtifactDriver struct { Endpoint string AccessKey string SecretKey string SecurityToken string }
ArtifactDriver is a driver for OSS
func (*ArtifactDriver) Delete ¶ added in v3.4.0
func (ossDriver *ArtifactDriver) Delete(s *wfv1.Artifact) error
Delete is unsupported for the oss artifacts
func (*ArtifactDriver) IsDirectory ¶ added in v3.4.0
func (g *ArtifactDriver) IsDirectory(artifact *wfv1.Artifact) (bool, error)
func (*ArtifactDriver) ListObjects ¶ added in v3.1.0
func (ossDriver *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)
func (*ArtifactDriver) Load ¶ added in v3.1.0
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 ¶ added in v3.4.0
func (ossDriver *ArtifactDriver) OpenStream(a *wfv1.Artifact) (io.ReadCloser, error)
Click to show internal directories.
Click to hide internal directories.