Function dispatch_local

nodedb/src/control/gateway/dispatcher.rs:87–96

Local dispatch via SPSC bridge.

(
    route: TaskRoute,
    shared: &Arc<SharedState>,
    tenant_id: TenantId,
    trace_id: TraceId,
)

/// Local dispatch via SPSC bridge.
async fn dispatch_local(
    route: TaskRoute,
    shared: &Arc<SharedState>,
    tenant_id: TenantId,
    trace_id: TraceId,
) -> Result<Vec<Vec<u8>>, Error> {
    let vshard_id = VShardId::new(route.vshard_id);
    let resp = dispatch_to_data_plane(shared, tenant_id, vshard_id, route.plan, trace_id).await?;
    Ok(vec![resp.payload.to_vec()])
}

/// Arguments for a remote dispatch call (bundles the 8 parameters to stay
/// within clippy's `too_many_arguments` limit).