Module region_server 

Modules

catalog 🔒

registrations 🔒

remote_dyn_filter 🔒

Structs

DummyCatalogList

Resolve to the given region (specified by RegionId) unconditionally.

DummyTableProviderFactory

PermitGuardedStream 🔒

Wraps a record batch stream and holds a concurrency permit until the stream is fully consumed (dropped), so max_concurrent_queries bounds the number of in-flight read streams, not just query planning.

RegionServer

RegionServerInner 🔒

RegionServerParallelism 🔒

RegionStat

RegionWatermarkStream 🔒

Wraps a region read stream so terminal metrics can carry the scan-open watermark.

Enums

CurrentEngine 🔒

RegionAttribute 🔒

RegionChange 🔒

RegionEngineWithStatus 🔒

Constants

QUERY_RUNTIME_STREAM_BUFFER_SIZE 🔒

Functions

is_metric_engine 🔒

maybe_guard_stream 🔒

Wraps stream so it holds permit until fully consumed. Returns stream unchanged when no permit was acquired (limiter disabled).

parse_region_attribute 🔒

wrap_flow_region_watermark_stream 🔒

Type Aliases

TableProviderFactoryRef