Skip to main content

map_subscription_request

Function map_subscription_request 

Source
pub fn map_subscription_request(
    request: &SubscriptionRequest,
) -> Result<MappedSubscription, ServerError>
Expand description

Map a wire subscription request onto the engine’s event filter surface.

The current engine filter supports workflow/run/family constraints only. The namespace dimension is enforced by the guard plus the per-event namespace gate; the workflow-type and status selectors are carried as a SubscriptionSelector and enforced server-side at the socket seam before any frame is encoded.

§Errors

Returns ServerError::Wire when the request omits its variant, omits the required per-workflow id, or carries an invalid proto identifier/status.