Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateArtifact ¶
func ValidateArtifact(errPrefix string, art *wfv1.HDFSArtifact) error
ValidateArtifact validates HDFS artifact
Types ¶
type ArtifactDriver ¶
type ArtifactDriver struct { Addresses []string // comma-separated name nodes Path string Force bool HDFSUser string KrbOptions *KrbOptions }
ArtifactDriver is a driver for HDFS
func CreateDriver ¶
func CreateDriver(ctx context.Context, ci resource.Interface, art *wfv1.HDFSArtifact) (*ArtifactDriver, error)
CreateDriver constructs ArtifactDriver
func (*ArtifactDriver) ListObjects ¶ added in v3.1.0
func (driver *ArtifactDriver) ListObjects(artifact *wfv1.Artifact) ([]string, error)
type CCacheOptions ¶
type CCacheOptions struct {
CCache credentials.CCache
}
CCacheOptions is options for ccache
type KeytabOptions ¶
KeytabOptions is options for keytab
type KrbOptions ¶
type KrbOptions struct { CCacheOptions *CCacheOptions KeytabOptions *KeytabOptions Config string ServicePrincipalName string }
KrbOptions is options for Kerberos
Click to show internal directories.
Click to hide internal directories.