impl

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 NewRegistry() interfaces2.WorkflowExecutorRegistry
• func PrepareFlyteWorkflow(data interfaces.ExecutionData, flyteWorkflow *v1alpha1.FlyteWorkflow) error
• type InterfaceProvider
• type K8sWorkflowExecutor
  • func NewK8sWorkflowExecutor(executionCluster execClusterInterfaces.ClusterInterface, ...) *K8sWorkflowExecutor
  • func (e K8sWorkflowExecutor) Abort(ctx context.Context, data interfaces.AbortData) error
  • func (e K8sWorkflowExecutor) Execute(ctx context.Context, data interfaces.ExecutionData) (interfaces.ExecutionResponse, error)
  • func (e K8sWorkflowExecutor) ID() string
• type LaunchPlanInterfaceProvider
  • func (p *LaunchPlanInterfaceProvider) GetExpectedInputs() *core.ParameterMap
  • func (p *LaunchPlanInterfaceProvider) GetExpectedOutputs() *core.VariableMap
  • func (p *LaunchPlanInterfaceProvider) GetID() *core.Identifier

Functions

func NewCompiler

func NewCompiler() interfaces.Compiler

func NewFlyteWorkflowBuilder

func NewFlyteWorkflowBuilder(scope promutils.Scope) interfaces.FlyteWorkflowBuilder

func NewLaunchPlanInterfaceProvider

func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)

func NewRegistry

func NewRegistry() interfaces2.WorkflowExecutorRegistry

func PrepareFlyteWorkflow

func PrepareFlyteWorkflow(data interfaces.ExecutionData, flyteWorkflow *v1alpha1.FlyteWorkflow) error

Types

type InterfaceProvider

type InterfaceProvider = common.InterfaceProvider

type K8sWorkflowExecutor

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

func NewK8sWorkflowExecutor(executionCluster execClusterInterfaces.ClusterInterface,
	workflowBuilder interfaces.FlyteWorkflowBuilder) *K8sWorkflowExecutor

func (K8sWorkflowExecutor) Abort

func (e K8sWorkflowExecutor) Abort(ctx context.Context, data interfaces.AbortData) error

func (K8sWorkflowExecutor) Execute

func (e K8sWorkflowExecutor) Execute(ctx context.Context, data interfaces.ExecutionData) (interfaces.ExecutionResponse, error)

func (K8sWorkflowExecutor) ID

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