Test implementation of IJWTVerifier.
A real verifier is supplied by the application, which knows what issues its
tokens. See wagoe.realtime.ports/IJWTVerifier.
Test implementation of IJWTVerifier. A real verifier is supplied by the application, which knows what issues its tokens. See `wagoe.realtime.ports/IJWTVerifier`.
Redis-backed IPubSubManager: topic subscriptions in Redis sets so they are visible cluster-wide.
Keys (optionally prefixed): topic:{t} -> SET of connection-id strings conn:{id} -> SET of topic strings (reverse index)
subscribe / unsubscribe apply both SADD/SREM atomically in a MULTI/EXEC. No explicit DEL on topic sets: Redis auto-removes a set key when its last member is removed, so empty topics disappear and the check-then-act DEL race cannot occur.
Redis-backed IPubSubManager: topic subscriptions in Redis sets so they are
visible cluster-wide.
Keys (optionally prefixed):
topic:{t} -> SET of connection-id strings
conn:{id} -> SET of topic strings (reverse index)
subscribe / unsubscribe apply both SADD/SREM atomically in a MULTI/EXEC.
No explicit DEL on topic sets: Redis auto-removes a set key when its last
member is removed, so empty topics disappear and the check-then-act DEL race
cannot occur.WebSocket connection adapter for Ring/Jetty.
Wraps Ring WebSocket implementation to provide IWebSocketConnection protocol. Handles JSON encoding/decoding and WebSocket frame transmission.
Responsibilities (Shell/I/O):
WebSocket connection adapter for Ring/Jetty. Wraps Ring WebSocket implementation to provide IWebSocketConnection protocol. Handles JSON encoding/decoding and WebSocket frame transmission. Responsibilities (Shell/I/O): - Send messages over WebSocket (I/O operation) - Close WebSocket connections (I/O operation) - JSON encoding (external format transformation) - Error handling and logging
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 |