Skip to main content

Module remote_dyn_filter_registry

query::dist_plan

Module remote_dyn_filter_registry 

Source

Structs§

DynFilterEntry
A registered query-local producer filter and its region subscribers.
DynFilterEntryState 🔒
DynFilterRegistryManager
Query-engine manager for query-scoped remote dynamic filter registries.
QueryDynFilterRegistry
Query-scoped registry that owns all remote dynamic filters for one query.
QueryDynFilterRegistryInner 🔒
RemoteDynFilterRegistryLease
Stream-scoped lease that keeps a query registry alive.
Subscriber
Region subscribed to a remote dynamic filter.

Enums§

ControlRpcResult 🔒
EntryRegistration
Result of registering a remote dynamic filter entry.
SubscriberRegistration
Result of registering a subscriber under an existing filter entry.

Constants§

REMOTE_DYN_FILTER_CONTROL_RPC_TIMEOUT 🔒
Bound best-effort RDF control RPCs so one bad subscriber cannot stall fanout.
REMOTE_DYN_FILTER_RECONCILE_INTERVAL 🔒
REMOTE_DYN_FILTER_UPDATE_PAYLOAD_MAX_BYTES 🔒

Functions§

await_control_rpc_or_lifecycle_close 🔒
await_control_rpc_timeout 🔒
current_stable_snapshot 🔒
ensure_entry_fanout_task 🔒
fanout_snapshot_for_query 🔒
fanout_update_for_query 🔒
run_entry_fanout 🔒
unregister_entry_once_for_query 🔒