Struct LimiterTask

struct LimiterTask {
    config: LimiterConfig,
    burst_budget_remaining: usize,
    last_check: Instant,
    metrics: LimiterMetrics,
}

A task that enforces configured memory limits.

The task operates by performing limit checks at a configured interval. For each check it obtains the current memory utilization from proc stats. It then compares the utilization against the configured memory limit, and if it exceeds the limit, reduces the burst budget by the amount of memory utilization that exceeds the limit. If the burst budget is exhausted, the limiter terminates the process.

Fields

config: LimiterConfig

The current limiter configuration.

burst_budget_remaining: usize

The amount of burst budget remaining.

last_check: Instant

The time of the last check.

metrics: LimiterMetrics

Metrics tracked by the limiter task.

Implementations

impl LimiterTask

async fn run( config_rx: UnboundedReceiver<LimiterConfig>, metrics: LimiterMetrics, )

async fn tick(&self)

Wait until the next check time.

fn current_utilization() -> Result<ProcStatus>

fn check(&mut self) -> Result<(), Error>

Perform a memory usage check, terminating the process if the configured limits are exceeded.

fn apply_config(&mut self, config: LimiterConfig)

Apply a new limiter config.