EventBroker.FilterAgent (Anoma v0.30.0)

I am a Filter Agent module.

I implement the base server behavior of the spawned filter agent. In general, I monitor subscribers of an individual filtering agent and send whichever events I receive to them.

Summary

Types

t()

I am the type of the Filter Agent.

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start_link(filter_params)

Types

t()

@type t() :: %EventBroker.FilterAgent{spec: struct(), subscribers: MapSet.t(pid())}

I am the type of the Filter Agent.

I contain the minimal info for a filter to work, namely the filter specification to apply to incoming messages and subscribers to send filtered messages to.

Fields

:spec - The filter specification. This is a structure of a module

      with a public filter API for the agent to call.

:subscribers - The list of subscribers to send filtered messages to.
```
             Default: MapSet.new()
```

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start_link(filter_params)

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