IO.Clock
in conduit v0.1.2
v0.1.2 declares IO.Clock. v0.1.1 did not. Declaring is the event recorded here — whether the capability was newly exercised is a separate claim the registry cannot make.
Where it is declared
lib/conduit/api.march:2Declared nothing in the previous version
1mod Conduit.API do
2 needs IO.Clock
3 doc """
4 Start the Conduit worker pool, cron scheduler, and workflow runner.
5
lib/conduit/config_app.march:2Declared nothing in the previous version
1mod Conduit.Config do
2 needs IO.Clock
3 fn default() do
4 {
5 queues: Cons("default", Nil),
lib/conduit/dead_letter.march:2Declared nothing in the previous version
1mod Conduit.DeadLetter do
2 needs IO.Clock
3 fn from_job(job : Conduit.JobRow, final_error : String) : Conduit.DeadLetter do
4 {
5 id: uuid_v7(()),
lib/conduit/queue.march:16Declared nothing in the previous version
13-- registered JobConfig (used for backoff, timeout, DLQ routing, and callbacks).
14mod Conduit.Queue do
15 needs IO.Mut
16 needs IO.Clock
17
18 doc """
19 Enqueue a job for immediate execution and return its id.
lib/conduit/rate_limiter.march:2Declared nothing in the previous version
1mod Conduit.RateLimiter do
2 needs IO.Clock
3 doc """
4 Attempt to acquire a rate-limit token for the given job.
5
lib/conduit/worker.march:20Declared nothing in the previous version
17-- reclaims jobs abandoned by workers that died mid-execution.
18mod Conduit.Worker do
19 needs IO.Spawn
20 needs IO.Clock
21
22 doc """
23 Start `count` worker tasks for the given queue, plus one stale-rescue task.
lib/conduit/workflow_context.march:2Declared nothing in the previous version
1mod Conduit.WorkflowContext do
2 needs IO.Clock
3 needs IO.Mut
4 doc "Create a root context for a new or resuming workflow execution."
5 fn new(workflow_id : String) : Conduit.WorkflowContext do
lib/conduit/workflow_runner.march:2Declared nothing in the previous version
1mod Conduit.WorkflowRunner do
2 needs IO.Clock
3 doc "The job_type constant (public so callers can use it in tests)."
4 fn job_type() : String do
5 "conduit.workflow_runner"