Skip to main content

write_prometheus_rows_with_progress

servers::http::prom_store

Function write_prometheus_rows_with_progress 

Source 
async fn write_prometheus_rows_with_progress(
    prom_store_handler: PromStoreProtocolHandlerRef,
    pending_rows_batcher: Option<Arc<PendingRowsBatcher>>,
    prom_store_with_metric_engine: bool,
    db: &str,
    query_ctx: Arc<QueryContext>,
    req: ContextReq,
) -> Result<PromWriteOutcome, PromWriteError>