ExStorageService.Cluster.Outbox.Dispatcher (ex_storage_service v0.6.4)

Copy Markdown View Source

Polls durable outbox pages and executes fenced jobs with bounded concurrency.

The GenServer owns only local scheduling state. Job ownership, retry timing, lease expiry, and fencing live in Concord and survive process/node restarts.

Summary

Functions

Returns a specification to start this module under a supervisor.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

process_jobs(server)

@spec process_jobs(GenServer.server()) :: :ok

start_link(opts)

@spec start_link(keyword()) :: GenServer.on_start()