Expand description
Owns the receive side of the CTP connection: a background task that pumps
ComputeResponses into per-id frontier watches, per-uuid peek channels, and
a raw broadcast. The mechanism does not curate which responses or which
frontier fields a use case may observe: frontier watches keep the full
merged FrontiersResponse, and the raw broadcast carries every response.
Structs§
- Compute
Sender - Send half: forwards commands into the pump task that owns the client.
- Responses
- Handle to the response side. Cloneable view onto frontier watches, peek routing, and the raw response broadcast.
- Shared 🔒
- Subscribe
State 🔒 - Buffered state for one subscribe sink: its accumulated updates, a watch on its upper frontier (so a waiter can block until it reaches a target), and the first error the replica reported, if any.
Type Aliases§
- Frontier
Rx 🔒 - Frontier
Tx 🔒