Readonly ExperimentalinitialPosition from which a freshly registered node reads its inbox.
Readonly ExperimentalnamespaceExperimental
Closes the backend's connections it owns.
Experimental
Deletes the retained message of a topic.
false if the topic had no retained message.
Experimental
Read-only getters, for dashboards. Lists are paginated like the queue
getters: start and end are inclusive positions (from 0), and an end
of -1 means "to the end". Orders are stable: nodes by registration,
subscriptions and patterns by value (bytewise), retained messages by
expiry.
Experimental
Namespaces of the datastore (or Redis prefix) with live nodes or retained messages, sorted by name.
Experimental
The inbox connection of a node, as the datastore sees it (from
CLIENT LIST or pg_stat_activity): where it connects from, and for
how long.
Empty when the node isn't connected. Lists every client connection of
the datastore, so use it on demand rather than polling it.
Experimental
All subscriptions, or those of a node or a pattern.
Experimental
Renews a node's lease.
false when the node is not registered or its lease expired, even if it was not swept. The caller must register again and restore its subscriptions.
Makes a blocked readInbox return, and later reads return without waiting: an interrupt that lands while a read is still querying (before it starts waiting) must not be lost.
Experimental
Experimental
Returns the next entries of a node's inbox, waiting up to blockMs when
there are none (0: return immediately).
Experimental
Registers (or refreshes) a node, its liveness lease and its info.
Optional_inboxMaxLength: numberExperimental
the number of subscriptions removed.
Experimental
Experimental
Removes up to limit nodes whose lease expired, with their subscriptions
and inboxes.
the ids of the removed nodes.
Experimental
Removes the entries of a node's inbox that were already consumed (up to
cursor, as returned by readInbox) and the oldest entries beyond
maxLength.
the number of entries left: the messages the node hasn't read yet (its backlog).
Experimental
Removes a node with its subscriptions and inbox.
Experimental
PostgreSQL implementation of IRelayBackend. Every operation is one of the
relay_*SQL functions (migration0004_relay); this class only passes arguments and decodes rows.Rows have no expiry in PostgreSQL: sweeps remove expired nodes (with their subscriptions and inboxes) and retained messages of every namespace, so a namespace whose nodes all vanished is cleaned by any node using the same schema.
Each node's inbox is a table, read after a
NOTIFYon thebullmq_relaychannel (or after the wait times out, so a missed notification only delays delivery). Entries are acknowledged by id, which never skips a row whose transaction committed late.