Expand description
Shard-side handler for incoming VShardEnvelope messages.
When a remote node sends a VShardEnvelope via QUIC (wrapped in
RaftRpc::VShardEnvelope), the transport server routes it here.
This handler dispatches based on VShardMessageType to the
appropriate engine handler:
- Graph BSP messages → graph algorithm shard handler
- Timeseries scatter → local scan + partial aggregate response
- Retention command → local retention enforcement
- S3 archive command → local archive execution
Enums§
- Dispatch
Target - Which engine subsystem should handle this envelope.
- Handle
Result - Result of handling a VShardEnvelope.
Traits§
- VShard
Handler - Trait for handling incoming VShardEnvelope messages on a shard.
Functions§
- build_
ts_ retention_ ack - Build a response envelope for a retention acknowledgement.
- build_
ts_ scatter_ response - Build a response envelope for a timeseries scatter response.
- dispatch_
by_ type - Default handler that dispatches based on message type.