ExESDBGater.Repl.Observer (ex_esdb_gater v0.1.0)

The Repl.Observer is a GenServer that:

- adds a transient subscription to the store.
- subscribes to the events emitted by the store, via Phoenix PubSub.
- prints the events to the console.

Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

start(args)

Starts an observer process for a given topic. ## Parameters

start_link(args)

topic(store, id)

topic(store, selector, name)

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

start(args)

@spec start(keyword()) :: pid()

Starts an observer process for a given topic. ## Parameters

store: The store to consume events from (atom, default: the configured store).
type: The type of subscription to consume events from (atom, default: :by_stream).
selector: The selector of the subscription to consume events from (string, default: "$all").
topic: The topic to consume events from (string, default: reg_gh:$all).
name: The name of the observer (string, default: transient).

start_link(args)

topic(store, id)

topic(store, selector, name)