impl

Documentation

Index

• func NewCompiler() interfaces.Compiler
• func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
• func NewNebulaWorkflowBuilder(scope promutils.Scope) interfaces.NebulaWorkflowBuilder
• func PrepareNebulaWorkflow(data interfaces.ExecutionData, nebulaWorkflow *v1alpha1.NebulaWorkflow) error
• type InterfaceProvider
• type K8sWorkflowExecutor
  • func NewK8sWorkflowExecutor(config runtimeInterfaces.Configuration, ...) *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 NewLaunchPlanInterfaceProvider

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

func NewNebulaWorkflowBuilder

func NewNebulaWorkflowBuilder(scope promutils.Scope) interfaces.NebulaWorkflowBuilder

func PrepareNebulaWorkflow

func PrepareNebulaWorkflow(data interfaces.ExecutionData, nebulaWorkflow *v1alpha1.NebulaWorkflow) error

Types

type InterfaceProvider

type InterfaceProvider = common.InterfaceProvider

type K8sWorkflowExecutor

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

K8sWorkflowExecutor directly creates and delete Nebula workflow execution CRD objects using the configured execution cluster interface.

func NewK8sWorkflowExecutor

func NewK8sWorkflowExecutor(config runtimeInterfaces.Configuration, executionCluster execClusterInterfaces.ClusterInterface, workflowBuilder interfaces.NebulaWorkflowBuilder, client *storage.DataStore) *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