Kathikon.Dispatcher (Kathikon v0.1.0)

Copy Markdown View Source

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.

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

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)