Cyclium.TriggerRequests (Cyclium v0.1.10)

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

create(attrs)

Expires trigger requests that have been pending longer than max_age_seconds.

Fetches up to limit pending trigger requests, oldest first.

mark_expired(id)

Expires trigger requests that have been pending longer than max_age_seconds.

:source_env — when present, only expires requests from this env, matched by strict equality (so a poller never GCs another env's pending requests). Pass nil to scope to the unset/default env; omit to expire across all envs. The poller passes its own env, mirroring fetch_pending/1.

Fetches up to limit pending trigger requests, oldest first.

:limit — max rows (default: 10)
:source_stack — when set, only requests from this stack (nil = any stack)
:source_env — when present, only requests from this env, matched by strict equality (so an env-tagged poller never claims the default env's requests). Pass nil to scope to the unset/default env; omit the key entirely to skip env filtering.

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