common

Documentation

Index

• Constants
• func DAGPublisher(ctx context.Context, opts driver.Options, mlmd *metadata.Client, ...) (err error)
• func ExecDriver(ctx context.Context, options *driverOptions) (*[]tektonv1beta1.CustomRunResult, bool, string, string, string, error)
• func GetKubernetesExecutorConfig(options *driverOptions) *kubernetesplatform.KubernetesExecutorConfig
• func ParseParams(run *tektonv1beta1.CustomRun) (*driverOptions, *apis.FieldError)
• func UpdateDAGPublisher(ctx context.Context, options *driverOptions, status pb.Execution_State) (err error)
• func UpdateOptionsDAGExecutionID(options *driverOptions, DAGExecutionID string)
• func UpdateOptionsIterationIndex(options *driverOptions, iterationIndex int)

Constants

const (
	// ReasonFailedValidation indicates that the reason for failure status is that Run failed runtime validation
	ReasonFailedValidation = "RunValidationFailed"

	// ReasonDriverError indicates that an error is throw while running the driver
	ReasonDriverError = "DriverError"

	ExecutionID    = "execution-id"
	Condition      = "condition"
	IterationCount = "iteration-count"
)

Functions

func DAGPublisher

func DAGPublisher(ctx context.Context, opts driver.Options, mlmd *metadata.Client, status pb.Execution_State) (err error)

func ExecDriver

func ExecDriver(ctx context.Context, options *driverOptions) (*[]tektonv1beta1.CustomRunResult, bool, string, string, string, error)

func GetKubernetesExecutorConfig

func GetKubernetesExecutorConfig(options *driverOptions) *kubernetesplatform.KubernetesExecutorConfig

func ParseParams

func ParseParams(run *tektonv1beta1.CustomRun) (*driverOptions, *apis.FieldError)

func UpdateDAGPublisher

func UpdateDAGPublisher(ctx context.Context, options *driverOptions, status pb.Execution_State) (err error)

func UpdateOptionsDAGExecutionID

func UpdateOptionsDAGExecutionID(options *driverOptions, DAGExecutionID string)

func UpdateOptionsIterationIndex

func UpdateOptionsIterationIndex(options *driverOptions, iterationIndex int)