EventBroker.Broker (Anoma v0.25.0)

I am a Broker module.

I specify the behavior of the server acting as a central broker of the PubSub servive. My functionality is minimal. I wait for messages and relay them to my subscribers.

Summary

Types

t()

I am the type of the Event Broker.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

init(opts)

Callback implementation for GenServer.init/1.

start_link(args \\ [])

Types

Link to this type

t()

@type t() :: %EventBroker.Broker{subscribers: MapSet.t(pid())}

I am the type of the Event Broker.

Fields

  • :subscribers - The set of pids showcasing subscribers.
                 Default: Map.Set.new()

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

init(opts)

Callback implementation for GenServer.init/1.

Link to this function

start_link(args \\ [])