Versions in this module Expand all Collapse all v0 v0.1.0 Sep 15, 2023 Changes in this version + type CallbackExecutor struct + func NewCallbackExecutor(ctx context.Context, s3 *s3.SwoopS3, conn db.Conn) *CallbackExecutor + func (cbx *CallbackExecutor) ProcessCallbacks(cbs Callbacks, wfProps *WorkflowProperties) error + type CallbackMap map[string]map[states.FinalState]Callbacks + func MapConfigCallbacks(sc *config.SwoopConfig) CallbackMap + func (cm CallbackMap) Lookup(wfName string, status states.FinalState) (Callbacks, bool) + type Callbacks []*config.Callback + type WorkflowProperties struct + ErrorMsg string + FinishedAt time.Time + Name string + StartedAt time.Time + Status states.WorkflowState + Uuid uuid.UUID + func (p *WorkflowProperties) LookupName(ctx context.Context, conn db.Conn) error + func (p *WorkflowProperties) ToEndEvent() *db.Event + func (p *WorkflowProperties) ToStartEvent() *db.Event