quasar_postgres/listener

Distributed PostgreSQL wake listener.

Notifications are hints only. Quasar’s periodic polling remains the recovery path whenever a notification is delayed or lost.

Types

opaque </>

pub opaque type Listener

</>

pub fn start(
  config: pog.Config,
  wake: fn(String) -> Nil,
) -> Result(Listener, dynamic.Dynamic)

Starts a dedicated LISTEN connection with automatic reconnect/backoff.

wake should signal the matching queue in the local Quasar runtime. The listener monitors its owner and shuts itself down when the owner exits.

</>

pub fn stop(listener: Listener) -> Nil