Skip to main content

ws_handler

risingwave_frontend::webhook::websocket

Function ws_handler 

Source 
pub async fn ws_handler(
    ws: WebSocketUpgrade,
    __arg1: Extension<Arc<IngestService>>,
    headers: HeaderMap,
    __arg3: Path<(String, String, String)>,
) -> Result<impl IntoResponse, WebhookError>