nodes

Documentation

Index

• func GetParentNodeMaxEndTime(ctx context.Context, w v1alpha1.ExecutableWorkflow, node v1alpha1.BaseNode) (t v1.Time, err error)
• func NewExecutor(ctx context.Context, store *storage.DataStore, ...) (executors.Node, error)
• func Resolve(ctx context.Context, h HandlerFactory, w v1alpha1.ExecutableWorkflow, ...) (*handler.Data, error)
• func ResolveBindingData(ctx context.Context, h HandlerFactory, w v1alpha1.ExecutableWorkflow, ...) (*core.Literal, error)
• type HandlerFactory
  • func NewHandlerFactory(ctx context.Context, executor executors.Node, eventSink events.EventSink, ...) (HandlerFactory, error)
• type PredicatePhase
  • func CanExecute(ctx context.Context, w v1alpha1.ExecutableWorkflow, node v1alpha1.BaseNode) (PredicatePhase, error)

Functions

func GetParentNodeMaxEndTime

func GetParentNodeMaxEndTime(ctx context.Context, w v1alpha1.ExecutableWorkflow, node v1alpha1.BaseNode) (t v1.Time, err error)

func NewExecutor

func NewExecutor(ctx context.Context, store *storage.DataStore, enQWorkflow v1alpha1.EnqueueWorkflow,
	revalPeriod time.Duration, eventSink events.EventSink, workflowLauncher launchplan.Executor,
	catalogClient catalog.Client, kubeClient executors.Client, scope promutils.Scope) (executors.Node, error)

func Resolve

func Resolve(ctx context.Context, h HandlerFactory, w v1alpha1.ExecutableWorkflow, nodeID v1alpha1.NodeID, bindings []*v1alpha1.Binding, store storage.ProtobufStore) (*handler.Data, error)

func ResolveBindingData

func ResolveBindingData(ctx context.Context, h HandlerFactory, w v1alpha1.ExecutableWorkflow, bindingData *core.BindingData, store storage.ProtobufStore) (*core.Literal, error)

Types

type HandlerFactory

type HandlerFactory interface {
	GetHandler(kind v1alpha1.NodeKind) (handler.IFace, error)
}

func NewHandlerFactory

func NewHandlerFactory(ctx context.Context,
	executor executors.Node,
	eventSink events.EventSink,
	workflowLauncher launchplan.Executor,
	enQWorkflow v1alpha1.EnqueueWorkflow,
	revalPeriod time.Duration,
	store *storage.DataStore,
	catalogClient catalog.Client,
	kubeClient executors.Client,
	scope promutils.Scope,
) (HandlerFactory, error)

type PredicatePhase

type PredicatePhase int

Special enum to indicate if the node under consideration is ready to be executed or should be skipped

const (
	// Indicates node is not yet ready to be executed
	PredicatePhaseNotReady PredicatePhase = iota
	// Indicates node is ready to be executed - execution should proceed
	PredicatePhaseReady
	// Indicates that the node execution should be skipped as one of its parents was skipped or the branch was not taken
	PredicatePhaseSkip
	// Indicates failure during Predicate check
	PredicatePhaseUndefined
)

func CanExecute

func CanExecute(ctx context.Context, w v1alpha1.ExecutableWorkflow, node v1alpha1.BaseNode) (PredicatePhase, error)