Documentation
¶
Index ¶
- func NewCompiler() interfaces.Compiler
- func NewFlyteWorkflowBuilder(scope promutils.Scope) interfaces.FlyteWorkflowBuilder
- func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
- func PrepareFlyteWorkflow(data interfaces.ExecutionData, flyteWorkflow *v1alpha1.FlyteWorkflow) error
- type InterfaceProvider
- type K8sWorkflowExecutor
- type LaunchPlanInterfaceProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCompiler ¶
func NewCompiler() interfaces.Compiler
func NewFlyteWorkflowBuilder ¶ added in v0.6.56
func NewFlyteWorkflowBuilder(scope promutils.Scope) interfaces.FlyteWorkflowBuilder
func NewLaunchPlanInterfaceProvider ¶
func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
func PrepareFlyteWorkflow ¶ added in v0.6.56
func PrepareFlyteWorkflow(data interfaces.ExecutionData, flyteWorkflow *v1alpha1.FlyteWorkflow) error
Types ¶
type InterfaceProvider ¶
type InterfaceProvider = common.InterfaceProvider
type K8sWorkflowExecutor ¶ added in v0.6.56
type K8sWorkflowExecutor struct {
// contains filtered or unexported fields
}
K8sWorkflowExecutor directly creates and delete Flyte workflow execution CRD objects using the configured execution cluster interface.
func NewK8sWorkflowExecutor ¶ added in v0.6.56
func NewK8sWorkflowExecutor(config runtimeInterfaces.Configuration, executionCluster execClusterInterfaces.ClusterInterface, workflowBuilder interfaces.FlyteWorkflowBuilder, client *storage.DataStore) *K8sWorkflowExecutor
func (K8sWorkflowExecutor) Abort ¶ added in v0.6.56
func (e K8sWorkflowExecutor) Abort(ctx context.Context, data interfaces.AbortData) error
func (K8sWorkflowExecutor) Execute ¶ added in v0.6.56
func (e K8sWorkflowExecutor) Execute(ctx context.Context, data interfaces.ExecutionData) (interfaces.ExecutionResponse, error)
func (K8sWorkflowExecutor) ID ¶ added in v0.6.56
func (e K8sWorkflowExecutor) ID() string
type LaunchPlanInterfaceProvider ¶
type LaunchPlanInterfaceProvider struct {
// contains filtered or unexported fields
}
func (*LaunchPlanInterfaceProvider) GetExpectedInputs ¶
func (p *LaunchPlanInterfaceProvider) GetExpectedInputs() *core.ParameterMap
func (*LaunchPlanInterfaceProvider) GetExpectedOutputs ¶
func (p *LaunchPlanInterfaceProvider) GetExpectedOutputs() *core.VariableMap
func (*LaunchPlanInterfaceProvider) GetID ¶
func (p *LaunchPlanInterfaceProvider) GetID() *core.Identifier
Source Files
Click to show internal directories.
Click to hide internal directories.