Wardrik.Notify.Server (wardrik v0.1.0-rc.1)

Copy Markdown

Sends notices. One runs per cluster.

It follows every agent's log and sends what each agent's route asks for. It saves its cursor after each event, so it picks up there after a restart. The first time it starts, it begins with new events.

Summary

Functions

after_terminate(terminate_return, info)

Callback implementation for DurableServer.after_terminate/2.

children(wardrik)

Returns the notifier's children: its supervisor, and a child that starts it there.

code_change(old_vsn, state, new_vsn)

Callback implementation for DurableServer.code_change/3.

handle_cast(request, state)

Callback implementation for DurableServer.handle_cast/2.

handle_continue(continue, state)

Callback implementation for DurableServer.handle_continue/2.

handle_sync(info, old_state, new_state)

Callback implementation for DurableServer.handle_sync/3.

init(state)

Callback implementation for DurableServer.init/1.

start(supervisor)

Starts the notifier under supervisor, unless it's already running in the cluster.

Functions

after_terminate(terminate_return, info)

Callback implementation for DurableServer.after_terminate/2.

children(wardrik)

@spec children(Wardrik.t()) :: [Supervisor.child_spec()]

Returns the notifier's children: its supervisor, and a child that starts it there.

code_change(old_vsn, state, new_vsn)

Callback implementation for DurableServer.code_change/3.

handle_cast(request, state)

Callback implementation for DurableServer.handle_cast/2.

handle_continue(continue, state)

Callback implementation for DurableServer.handle_continue/2.

handle_sync(info, old_state, new_state)

Callback implementation for DurableServer.handle_sync/3.

init(state)

Callback implementation for DurableServer.init/1.

start(supervisor)

@spec start(atom()) :: :ignore | {:error, term()}

Starts the notifier under supervisor, unless it's already running in the cluster.