Struct mz_persist_client::internal::metrics::MetricsSemaphore

pub struct MetricsSemaphore {
    name: &'static str,
    semaphore: Arc<Semaphore>,
    total_permits: usize,
    acquire_count: IntCounter,
    blocking_count: IntCounter,
    blocking_seconds: Counter,
    acquired_permits: IntCounter,
    released_permits: IntCounter,
    _available_permits: ComputedUIntGauge,
}

Fields

name: &'static str

semaphore: Arc<Semaphore>

total_permits: usize

acquire_count: IntCounter

blocking_count: IntCounter

blocking_seconds: Counter

acquired_permits: IntCounter

released_permits: IntCounter

_available_permits: ComputedUIntGauge

Implementations

impl MetricsSemaphore

pub fn new( registry: &MetricsRegistry, name: &'static str, total_permits: usize, ) -> Self

pub async fn acquire_permits(&self, requested_permits: usize) -> MetricsPermits

Trait Implementations

impl Debug for MetricsSemaphore

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

Formats the value using the given formatter.