Skip to main content

fanout_update_for_query

query::dist_plan::remote_dyn_filter_registry

Function fanout_update_for_query 

Source 
async fn fanout_update_for_query(
    query_id: QueryId,
    region_query_handler: &RegionQueryHandlerRef,
    entry: &DynFilterEntry,
    generation: u64,
    is_complete: bool,
    payload: Vec<u8>,
    lifecycle_rx: &mut Receiver<()>,
    control_rpc_timeout: Duration,
) -> bool