automations

func FenceOn ¶

func FenceOn(client *ent.Client) Fencer

FenceOn is the Fencer of a database with real connections (ADR 0046): effect runs while a share lock is held on the Enrollment's row, taken only if the row is still `active`. Every move out of `active` is an UPDATE of that row, and an UPDATE waits for a share lock, so

• an exit that arrives while the effect is in flight returns only after it finished: the effect is ordered before the exit, never after it;
• an exit committed before the lock is seen under it (the lock's WHERE is re-checked once a concurrent update commits), so the effect never starts.

The lock lives on a transaction of its own that does nothing else, and effect runs on the pool's other connections as it always did: the step's compare-and-swap that follows (Advance, Complete, Fail) is made after the lock is released, so it cannot wait on itself, and the outbound claim, lease and idempotency key are untouched. The hold lasts as long as effect runs, which the job's context, the provider's and the HTTP client's timeouts bound; the transaction ends when effect returns or ctx is done. Only the lock is read-only, so there is nothing to commit.

The lock needs one pool connection beyond the effect's own for the effect's duration.

func New ¶

func New(cipher *secrets.Cipher, bus *events.Bus) *Module

New builds the automations module. It holds no client: every call takes the Workspace's scoped client (ADR 0017). The cipher seals an HTTP step's secrets; the bus opens the transaction that saves an Automation together with its steps.

func CurrentSteps ¶

func CurrentSteps(a *ent.Automation) ([]Step, error)

CurrentSteps decodes the steps of the Automation's latest version, which the Automations this module returns carry. An Automation that was loaded some other way has none.

func Decode ¶

func Decode(definition string) ([]Step, error)

Decode parses a stored definition. An empty definition has no steps.