Struct EnvelopeRouter 

pub struct EnvelopeRouter;

Handles routing of envelopes between clients and workers.

Implementations

impl EnvelopeRouter

pub async fn route_request( state: Arc<GatewayState>, envelope: PeerRpcEnvelope, timeout: Duration, ) -> PeerRpcResponse

Routes an inbound client request envelope to a worker.

Resolves the target worker, registers a pending request channel, forwards the envelope, and awaits the response from the worker.

pub fn handle_worker_response( state: Arc<GatewayState>, tenant_id: &TenantId, response: PeerRpcResponse, ) -> GatewayResult<()>

Dispatches a response received from a worker to the waiting client’s task.

pub fn handle_worker_response_from( state: Arc<GatewayState>, tenant_id: &TenantId, worker: &WorkerConnection, response: PeerRpcResponse, ) -> GatewayResult<()>

Dispatches a response only when it came from the selected worker connection.

pub async fn route_mesh_request( state: Arc<GatewayState>, request: MeshPeerRequest, timeout: Duration, ) -> MeshPeerResponse

Routes a mesh relay request to the target worker socket.

pub fn handle_worker_mesh_response( state: Arc<GatewayState>, tenant_id: &TenantId, response: MeshPeerResponse, ) -> GatewayResult<()>

Dispatches a mesh response received from a worker to the waiting relay task.

pub fn handle_worker_mesh_response_from( state: Arc<GatewayState>, tenant_id: &TenantId, worker: &WorkerConnection, response: MeshPeerResponse, ) -> GatewayResult<()>

Dispatches a mesh response only when it came from the selected worker connection.