EventBroker.Broker (Anoma v0.29.0)

I am a Broker module.

I specify the behavior of the server acting as a central broker of the PubSub service. 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.

start_link(args \\ [])

Types

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

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(args \\ [])

@spec start_link(list()) :: GenServer.on_start()