Claims and executes jobs for a single queue.
One dispatcher runs per queue under Kathikon.Queue. It polls Mnesia on
poll_interval, atomically claims jobs, and spawns Tasks up to the
configured concurrency.
start_link/1 options
:queue,:config,:poll_interval— required queue settings:storage— module implementingKathikon.Backend.Storagecallbacks (defaultKathikon.Storage)
Registered in Kathikon.Registry as {:dispatcher, queue}.
See docs/guides/queues-and-concurrency.md.
Summary
Functions
Returns a specification to start this module under a supervisor.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.