Node boundary: read the discovery file, subscribe to the bridge's SSE stream, apply each :json native on the host, and POST the reply. Reconnects with capped backoff, re-reading discovery each attempt.
Node boundary: read the discovery file, subscribe to the bridge's SSE stream, apply each :json native on the host, and POST the reply. Reconnects with capped backoff, re-reading discovery each attempt.
(backoff-ms n)Delay before reconnect attempt N (0-based): 500ms doubling, capped at 15s.
Delay before reconnect attempt N (0-based): 500ms doubling, capped at 15s.
(client host
{:keys [discovery-path on-state on-reply auto-reconnect?]
:or {auto-reconnect? true}})Client over HOST. opts: :discovery-path, :on-state (fn [state]), :on-reply (fn [payload reply]), :auto-reconnect? (default true).
Client over HOST. opts: :discovery-path, :on-state (fn [state]), :on-reply (fn [payload reply]), :auto-reconnect? (default true).
(connect! client)Open (or reopen) the stream for CLIENT. Returns CLIENT.
Open (or reopen) the stream for CLIENT. Returns CLIENT.
(disconnect! client)Stop CLIENT: cancel any pending reconnect and close the stream.
Stop CLIENT: cancel any pending reconnect and close the stream.
(read-discovery path)Discovery map with string keys, or nil when absent or unreadable.
Discovery map with string keys, or nil when absent or unreadable.
(restart! client)Reconnect a stopped or disconnected CLIENT now.
Reconnect a stopped or disconnected CLIENT now.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |