Expand description
Bounded per-user room output.
UserOutboundSender::send enqueues without waiting and signals
UserOutboundEvent::Overflow when message-count or byte capacity is
exhausted. UserOutboundReceiver::recv_event prioritizes that signal over
queued output. User-session loops must stop normal draining after overflow.
Structsยง
- Broadcast
Payload - Json
Byte ๐Counter - Message
Fanout ๐ - Queued
User ๐Outbound - Remote
Track Projection - Remote
Track Snapshot - User
Outbound Overflow - queue overflow details captured when a user cannot accept more outbound work
- User
Outbound Queue Limits - message and byte capacity for one user outbound queue
- User
Outbound Receiver - User
Outbound Sender - Versioned
Remote ๐Track Snapshot
Enumsยง
- Broadcast
Payload Error - Room
Event Message - User
Outbound - room output that belongs to one connected user
- User
Outbound Event - receiver-side queue event for user-session loops
- User
Outbound Overflow Kind - outbound queue limit that rejected a message
- User
Outbound Send Error - non-blocking outbound send failure
Constantsยง
- BROADCAST_
QUEUE_ ๐OVERHEAD_ BYTES - DEFAULT_
USER_ OUTBOUND_ QUEUE_ BYTE_ CAPACITY - DEFAULT_
USER_ OUTBOUND_ QUEUE_ CAPACITY - MAX_
BROADCAST_ PAYLOAD_ BYTES - ROOM_
EVENT_ ๐QUEUE_ BYTES - TRACK_
PROJECTION_ ๐QUEUE_ OVERHEAD_ BYTES
Functionsยง
- fanout_
all ๐ - serialized_
json_ ๐len - wait_
for_ ๐overflow
Type Aliasesยง
- Outbound
Sender ๐