Struct mz_persist_client::internal::metrics::SemaphoreMetrics

pub struct SemaphoreMetrics {
    cfg: PersistConfig,
    registry: MetricsRegistry,
    fetch: OnceCell<MetricsSemaphore>,
}

Fields

cfg: PersistConfig

registry: MetricsRegistry

fetch: OnceCell<MetricsSemaphore>

Implementations

impl SemaphoreMetrics

fn new(cfg: PersistConfig, registry: MetricsRegistry) -> Self

async fn fetch(&self) -> &MetricsSemaphore

We can’t easily change the number of permits, and the dyncfgs are all set to defaults on process start, so make sure we only initialize the semaphore once we’ve synced dyncfgs at least once.

pub(crate) async fn acquire_fetch_permits( &self, encoded_size_bytes: usize, ) -> MetricsPermits

Trait Implementations

impl Debug for SemaphoreMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.