Cyclium.TriggerRequests (Cyclium v0.1.5)

Copy Markdown

Context module for deferred trigger requests.

Trigger requests are created by Runner.Deferred on trigger-only nodes and picked up by TriggerRequests.Poller on full-mode nodes.

Summary

Functions

Expires trigger requests that have been pending longer than max_age_seconds.

Fetches up to limit pending trigger requests, oldest first. Optionally scopes to requests from a specific source stack.

Functions

create(attrs)

expire_stale(max_age_seconds \\ 3600)

Expires trigger requests that have been pending longer than max_age_seconds.

fetch_pending(opts \\ [])

Fetches up to limit pending trigger requests, oldest first. Optionally scopes to requests from a specific source stack.

Does not modify the rows — claiming is handled via WorkClaims.

mark_claimed(id, claimer_node)

mark_completed(id)

mark_expired(id)