Skip to main content

Module vshard_handler

Module vshard_handler 

Source
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§

DispatchTarget
Which engine subsystem should handle this envelope.
HandleResult
Result of handling a VShardEnvelope.

Traits§

VShardHandler
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.