IO.Mut
in conduit v0.1.2
v0.1.2 declares IO.Mut. 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/cron.march:11Declared nothing in the previous version
8-- a named table. `Vault.new` is idempotent, so the registry is process-global
9-- and shared across all callers in the same OS process.
10mod Conduit.CronRegistry do
11 needs IO.Mut
12 ptype Entry = {
13 config : Conduit.CronConfig,
14 performer : String -> Result((), Conduit.ConduitError)
lib/conduit/event_store.march:2Declared nothing in the previous version
1mod Conduit.EventStore do
2 needs IO.Mut
3 doc "The Vault namespace key used for replay state of a given workflow."
4 fn replay_key(workflow_id : String) do
5 let name = "conduit_wf_replay_" ++ workflow_id
lib/conduit/node.march:22Declared nothing in the previous version
19-- Override via `CONDUIT_HOSTNAME` for bare-metal deployments that use a
20-- non-standard env variable.
21mod Conduit.Node do
22 needs IO.Mut
23 needs IO.Spawn
24 needs IO.Process
25
lib/conduit/queue.march:15Declared nothing in the previous version
12-- Workers call `dispatch` to execute a job and `lookup_config` to read the
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 """
lib/conduit/queue_control.march:12Declared nothing in the previous version
9-- State is stored in a Vault table so it is visible to all worker tasks in
10-- the same process without any DB round-trip.
11mod Conduit.QueueControl do
12 needs IO.Mut
13
14 doc """
15 Pause all workers polling `queue` on this node.
lib/conduit/shutdown.march:12Declared nothing in the previous version
9-- individually. It is never reset automatically; restart the process to
10-- resume processing after a drain.
11mod Conduit.Shutdown do
12 needs IO.Mut
13
14 doc """
15 Signal all workers on this node to stop polling for new jobs.
lib/conduit/storage/postgres.march:31
28--
29-- Schema: priv/migrations/001_conduit_schema.sql
30mod Conduit.Storage.Postgres do
31 needs IO.Mut
32 use Conduit
33 import Connection
34 import Db
lib/conduit/workflow_context.march:3Declared 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
6 {
lib/conduit/workflow_registry.march:2Declared nothing in the previous version
1mod Conduit.WorkflowRegistry do
2 needs IO.Mut
3
4 type WorkflowEntry = { config : Conduit.WorkflowConfig }
5