Documentation
¶
Index ¶
- func NewCompiler() interfaces.Compiler
- func NewFlytePropeller(roleNameKey, kubeConfig, master string, ...) interfaces.Executor
- func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
- type FlytePropeller
- 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, kubeConfig, master string, configuration runtimeInterfaces.ClusterConfiguration, scope promutils.Scope) 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 (c *FlytePropeller) ExecuteWorkflow(ctx context.Context, inputs interfaces.ExecuteWorkflowInputs) error
func (*FlytePropeller) TerminateWorkflowExecution ¶
func (c *FlytePropeller) TerminateWorkflowExecution( ctx context.Context, executionID *core.WorkflowExecutionIdentifier) 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.