environment

Documentation

Index

• type Environment
• type Event
• type Function
• type MapEvents
• type MapFunctions
• type MapStates
• type NewEnvironment
• type State

Types

type Environment

type Environment interface {
	Spec() model.Workflow
	InitializeWorkflow(spec model.Workflow, busEvent bus.Bus) error
	Start() string
	State(name string) State
	CompensateBy(transition State) error
}

type Event

type Event interface {
	Produce(ctx context.Context, data model.Object) error
	Consume(ctx context.Context) (cloudevents.Event, error)
}

type Function

type Function interface {
	Init() error
	Run(data model.Object) (model.Object, error)
}

type MapEvents

type MapEvents map[string]Event

type MapFunctions

type MapFunctions map[string]Function

type MapStates

type MapStates map[string]State

type NewEnvironment

type NewEnvironment func() Environment

type State

type State interface {
	Type() model.StateType
	Name() string

	FilterInput(model.Object) (model.Object, error)
	FilterOutput(model.Object) (model.Object, error)
	Run(ctx context.Context, dataIn model.Object) (model.Object, error)
	ProduceEvents(ctx context.Context, data model.Object) error
	Next() (string, bool)
}