Skip to main content

handle_array_shard_rpc

nodedb_cluster::distributed_array::handler

Function handle_array_shard_rpc 

Source 
pub async fn handle_array_shard_rpc(
    opcode: u32,
    local_vshard_id: u32,
    payload: &[u8],
    executor: &Arc<dyn ArrayLocalExecutor>,
) -> Result<Vec<u8>>
Expand description

Dispatch an incoming array shard RPC to the appropriate local handler.

opcode is the VShardMessageType discriminant (u16). local_vshard_id is this shard’s own vShard ID (for routing validation). payload is the zerompk-encoded request body. executor reaches into the local Data Plane array engine.

Returns the zerompk-encoded response body on success, ready to be placed into a response VShardEnvelope.