Expand description
One receiver and processing scheduler for each client context.
Structs§
- Incoming
Coordinator - Shares receipt and ordered processing across all readers in one context. Database transactions provide the cross-process safety boundary.
- Incoming
Lease - Holds network interest and scope status; application acknowledgement is separate.
- Incoming
Runtime - Shared client runtime. Transport capability and limits are fixed at construction. The controller slot orders its final release with the next reader acquisition.
- Incoming
Status - Current scope status plus the immediately replaced scope’s cancellation result.
- Incoming
Topic Status - Per-topic proof of durable receipt and processing through one fixed head.
Enums§
- Incoming
Connection - Transport health; a connected wire does not imply completed processing.
- Incoming
Error - Incoming
Processing - Processing state through the fixed targets, independent of application delivery.
- Incoming
Receive Policy - When a fixed-target operation may query beyond durable receipt.
- Incoming
Registration - Whether this topic still has network interest for the current scope.
- Incoming
Scope - Network interest held by one reader or bounded sync run.