impl

Documentation

Index

• func NewCompiler() interfaces.Compiler
• func NewFlytePropeller(roleNameKey string, executionCluster interfaces2.ClusterInterface, ...) interfaces.Executor
• func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
• type FlytePropeller
  • func (c *FlytePropeller) ExecuteTask(ctx context.Context, input interfaces.ExecuteTaskInput) (*interfaces.ExecutionInfo, error)
  • func (c *FlytePropeller) ExecuteWorkflow(ctx context.Context, input interfaces.ExecuteWorkflowInput) (*interfaces.ExecutionInfo, error)
  • func (c *FlytePropeller) TerminateWorkflowExecution(ctx context.Context, input interfaces.TerminateWorkflowInput) error
• type FlyteWorkflowBuilder
  • func (b *FlyteWorkflowBuilder) BuildFlyteWorkflow(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, ...) (*v1alpha1.FlyteWorkflow, error)
• type InterfaceProvider
• 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 NewFlytePropeller

func NewFlytePropeller(roleNameKey string, executionCluster interfaces2.ClusterInterface,
	scope promutils.Scope, configuration runtimeInterfaces.NamespaceMappingConfiguration) interfaces.Executor

func NewLaunchPlanInterfaceProvider

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

Types

type FlytePropeller

type FlytePropeller struct {
	// contains filtered or unexported fields
}

func (*FlytePropeller) ExecuteTask

func (c *FlytePropeller) ExecuteTask(ctx context.Context, input interfaces.ExecuteTaskInput) (*interfaces.ExecutionInfo, error)

func (*FlytePropeller) ExecuteWorkflow

func (c *FlytePropeller) ExecuteWorkflow(ctx context.Context, input interfaces.ExecuteWorkflowInput) (*interfaces.ExecutionInfo, error)

func (*FlytePropeller) TerminateWorkflowExecution

func (c *FlytePropeller) TerminateWorkflowExecution(
	ctx context.Context, input interfaces.TerminateWorkflowInput) error

type FlyteWorkflowBuilder

type FlyteWorkflowBuilder struct{}

func (*FlyteWorkflowBuilder) BuildFlyteWorkflow

func (b *FlyteWorkflowBuilder) BuildFlyteWorkflow(
	wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, executionID *core.WorkflowExecutionIdentifier,
	namespace string) (*v1alpha1.FlyteWorkflow, error)

type InterfaceProvider

type InterfaceProvider = common.InterfaceProvider

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