Rig.EventFilter.Server (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Filter for the event subscription mechanism.

For each event type, on each node, there is exactly one EventFilter (Server). The Filter keeps track of subscriptions. Subscriptions have a time-to-live, that is, if they're not renewed for some time, the Filter will remove them eventually.

Link to this section Summary

Types

event_type()

Functions

add_wildcards_to_table(table, n_cur_fields, n_new_fields)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

process(event_type)

remove_expired_records(map)

start(event_type, config, opts \\ [])

start_link(event_type, config, opts \\ [])

Link to this section Types

event_type()

Specs

event_type() :: String.t()

Link to this section Functions

add_wildcards_to_table(table, n_cur_fields, n_new_fields)

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

process(event_type)

remove_expired_records(map)

start(event_type, config, opts \\ [])

Specs

start(event_type(), Rig.EventFilter.Config.event_type_config(), list()) ::
  {:ok, pid()}

start_link(event_type, config, opts \\ [])

Specs

start_link(event_type(), Rig.EventFilter.Config.event_type_config(), list()) ::
  {:ok, pid()}