impl

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2019 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) ExecuteWorkflow

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL