servers::http::prom_store

Function decode_remote_write_request

Source 
async fn decode_remote_write_request(
    is_zstd: bool,
    body: Bytes,
    prom_validation_mode: PromValidationMode,
    processor: &mut PromSeriesProcessor,
) -> Result<ContextReq>