workflow

Documentation

Index

• func ValidateFlows(wf *serverlessv1alpha1.Workflow) error
• func ValidateFuncExist(wf *serverlessv1alpha1.Workflow, fl *serverlessv1alpha1.FunctionList) error
• type Reconciler
  • func NewReconciler(cli client.Client, l logr.Logger, s *runtime.Scheme, ...) (*Reconciler, error)
  • func (r *Reconciler) Reconcile() error

Functions

func ValidateFlows

func ValidateFlows(wf *serverlessv1alpha1.Workflow) error

ValidateFlows validates wether the graph of Flows is legal or not For every Flow, it should obey the following rules:

• Has one and only one entrance
• Has one and at least one exit
• Every Flow in Inputs & Outputs should have been defined in []Flow
• If a Flow has a Condition, every Flow in Condition.Destination should have been defined in Outputs

func ValidateFuncExist

func ValidateFuncExist(wf *serverlessv1alpha1.Workflow, fl *serverlessv1alpha1.FunctionList) error

ValidateFuncExist validates that each Function declared in the workflow has been defined in Function CRD, or it will return error

Types

type Reconciler

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

func NewReconciler

func NewReconciler(cli client.Client, l logr.Logger,
	s *runtime.Scheme, i *serverlessv1alpha1.Workflow) (*Reconciler, error)

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile() error