nodes

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 18, 2019 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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)

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
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL