serve_ingestion

Function serve_ingestion 

Source
pub async fn serve_ingestion(
    listen_addr: SocketAddr,
    lake: DataLakeConnection,
    auth_provider: Option<Arc<dyn AuthProvider>>,
    shutdown: impl Future<Output = ()> + Send + 'static,
    grace: Duration,
) -> Result<()>
Expand description

Assemble and serve the HTTP ingestion endpoint.

Binds listen_addr, wires the ingestion routes + OTLP routes, applies the supplied auth_provider (or runs open when None), and shuts down gracefully when shutdown resolves.