elsa

v0.12.3

elsa v0.12.3 Elsa.Group.Supervisor

Orchestrates the creation of dynamic supervisor and worker processes for per-topic consumer groups, manager processes for coordinating topic/partition assignment, and a registry for differentiating named processes between consumer groups.

Link to this section Summary

Types

init_opts()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(init_arg \\ [])

Link to this section Types

Link to this type

init_opts()

init_opts() :: [
  connection: Elsa.connection(),
  topics: [Elsa.topic()],
  group: String.t(),
  config: list()
]

Link to this section Functions

Link to this function

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

start_link(init_arg \\ [])

start_link(init_opts()) :: GenServer.on_start()