Jido.Signal.Bus.PartitionSupervisor (Jido Signal v2.2.1)

View Source

Supervises partition workers for a bus.

Each bus with partition_count > 1 will have a PartitionSupervisor that manages the partition workers. This enables horizontal scaling of signal dispatch.

Summary

Functions

Returns a specification to start this module under a supervisor.

Starts the partition supervisor.

Returns a via tuple for looking up a partition supervisor by bus name.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(opts)

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

Starts the partition supervisor.

Options

  • :bus_name - The name of the parent bus (required)
  • :bus_pid - The PID of the parent bus (required)
  • :partition_count - Number of partitions to create (default: 1)
  • :middleware - Middleware configurations (optional)
  • :middleware_timeout_ms - Timeout for middleware execution (default: 100)
  • :journal_adapter - Journal adapter module (optional)
  • :journal_pid - Journal adapter PID (optional)

via_tuple(bus_name, opts \\ [])

@spec via_tuple(
  atom(),
  keyword()
) :: {:via, Registry, {module(), tuple()}}

Returns a via tuple for looking up a partition supervisor by bus name.