try_cached_replay

Function try_cached_replay 

Source
pub(super) async fn try_cached_replay(
    state: &AppState,
    cache_key: &str,
    layout: ParquetLayout,
    stream_shapes: StreamShapes,
    data_model_entities: DataModelEntities,
) -> Result<Option<Response>, ApiError>
Expand description

Try to serve a parse_parquet_stream request from the cache. Returns Ok(Some(response)) on a usable cache hit (the caller drops its admission guard and returns the response as-is), Ok(None) on a miss or a short/corrupt cached blob (the caller falls through to the live parse, which overwrites the bad entry).