impl

Documentation

Index

• func NewCompiler() interfaces.Compiler
• func NewKozmoWorkflowBuilder(scope promutils.Scope) interfaces.KozmoWorkflowBuilder
• func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)
• func PrepareKozmoWorkflow(data interfaces.ExecutionData, kozmoWorkflow *v1alpha1.KozmoWorkflow) 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 NewKozmoWorkflowBuilder

func NewKozmoWorkflowBuilder(scope promutils.Scope) interfaces.KozmoWorkflowBuilder

func NewLaunchPlanInterfaceProvider

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

func PrepareKozmoWorkflow

func PrepareKozmoWorkflow(data interfaces.ExecutionData, kozmoWorkflow *v1alpha1.KozmoWorkflow) error

Types

type InterfaceProvider

type InterfaceProvider = common.InterfaceProvider

type K8sWorkflowExecutor

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

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

func NewK8sWorkflowExecutor

func NewK8sWorkflowExecutor(config runtimeInterfaces.Configuration, executionCluster execClusterInterfaces.ClusterInterface, workflowBuilder interfaces.KozmoWorkflowBuilder, 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