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
- type InterfaceProvider
- type LaunchPlanInterfaceProvider
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) ExecuteTask ¶ added in v0.2.8
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
Click to show internal directories.
Click to hide internal directories.