internal

Documentation

Index

• Variables
• func CreateStep(c px.Context, def serviceapi.Definition) wfe.Step
• func GetIdentity(c px.Context) serviceapi.Identity
• func GetLazyIdentity(c px.Context) (li serviceapi.Identity)
• func NewEach(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator
• func NewEachPair(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator
• func NewRange(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator
• func NewTimes(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator
• func StepId(a wfe.Step) string
• func StepLabel(a wfe.Step) string
• func Validate(it wfe.Iterator)
• type WorkflowEngine

Variables

var DefinitionListType = types.NewArrayType(serviceapi.DefinitionMetaType, nil)

var IdentityId = px.NewTypedName(px.NsDefinition, "Identity::Service")

Functions

func CreateStep

func CreateStep(c px.Context, def serviceapi.Definition) wfe.Step

func GetIdentity

func GetIdentity(c px.Context) serviceapi.Identity

func GetLazyIdentity

func GetLazyIdentity(c px.Context) (li serviceapi.Identity)

func NewEach

func NewEach(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator

func NewEachPair

func NewEachPair(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator

func NewRange

func NewRange(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator

func NewTimes

func NewTimes(step wfe.Step, name string, over px.Value, variables []serviceapi.Parameter) wfe.Iterator

func StepId

func StepId(a wfe.Step) string

func StepLabel

func StepLabel(a wfe.Step) string

func Validate

func Validate(it wfe.Iterator)

Types

type WorkflowEngine

type WorkflowEngine interface {
	Run(ctx px.Context, parameters px.OrderedMap) px.OrderedMap

	BuildInvertedGraph(ctx px.Context, existsFunc func(string) bool)

	GraphAsDot() []byte

	// Validate ensures that all consumed values have a corresponding producer and that only
	// one producer exists for each produced value.
	Validate()
}