Method make_request_process_future

influxdb3_processing_engine/src/plugins.rs:575–581

Create a boxed future for processing HTTP request events.

(
        &self,
        request: crate::Request,
    )

    /// Create a boxed future for processing HTTP request events.
    fn make_request_process_future(
        &self,
        request: crate::Request,
    ) -> BoxFuture<'static, Result<(), PluginError>> {
        let clone = self.clone();
        Box::pin(async move { clone.process_request(request).await })
    }

    /// Process a single HTTP request, execute the plugin, and send the response.
    async fn process_request(&self, request: crate::Request) -> Result<(), PluginError> {