Kitto v0.9.1 Kitto.Notifier View Source

Module responsible for broadcasting events across connections.

Link to this section Summary

Functions

broadcast!(data, topic)

Emits a server-sent event to each of the active connections with the given topic and payload

broadcast!(pid, topic, data)

Emits a server-sent event to each of the active connections with the given topic and payload to a specific process

cache()

Returns cached broadcasts

cache(topic, data)

Caches the given payload with the key provided as the first argument

child_spec(arg)

Returns a specification to start this module under a supervisor

clear_cache()

Resets the broadcast cache

connections()

Returns the registered connections

delete(conn)

Removes a connection from the connections list

initial_broadcast!(pid)

Every new SSE connection gets all the cached payloads for each job. The last broadcasted payload of each job is cached

Updates the list of connections to use for broadcasting

start_connections_cache()

Starts the connections cache agent

start_link()

Starts the notifier supervision tree

start_notifier_cache()

Starts the notifier cache agent

Link to this section Functions