README
- ::equalDeltaError::equal
- ::not_equalDeltaError::not_equal
- ::to_reprDeltaError::to_repr
- ::equalParseError::equal
- ::not_equalParseError::not_equal
- ::to_reprParseError::to_repr
- ::equalAdmission::equal
- ::labelAdmission::label
- ::not_equalAdmission::not_equal
- ::to_reprAdmission::to_repr
- ::equalAdvice::equal
- ::not_equalAdvice::not_equal
- ::to_jsonAdvice::to_json
- ::to_reprAdvice::to_repr
- ::equalBudget::equal
- ::not_equalBudget::not_equal
- ::to_jsonBudget::to_json
- ::to_reprBudget::to_repr
- ::newController::new
- ::resetController::reset
- ::updateController::update
- ::equalCpuMax::equal
- ::not_equalCpuMax::not_equal
- ::to_reprCpuMax::to_repr
- ::equalCpuStat::equal
- ::not_equalCpuStat::not_equal
- ::to_reprCpuStat::to_repr
- ::equalInterval::equal
- ::not_equalInterval::not_equal
- ::to_jsonInterval::to_json
- ::to_reprInterval::to_repr
- ::equalLayer::equal
- ::not_equalLayer::not_equal
- ::parseLayer::parse
- ::to_reprLayer::to_repr
- ::equalLimit::equal
- ::not_equalLimit::not_equal
- ::to_reprLimit::to_repr
- ::equalMemoryEvents::equal
- ::not_equalMemoryEvents::not_equal
- ::to_reprMemoryEvents::to_repr
- ::equalPolicy::equal
- ::newPolicy::new
- ::not_equalPolicy::not_equal
- ::to_reprPolicy::to_repr
- ::equalPressure::equal
- ::not_equalPressure::not_equal
- ::to_reprPressure::to_repr
- ::equalPressureLine::equal
- ::not_equalPressureLine::not_equal
- ::to_reprPressureLine::to_repr
- ::equalReason::equal
- ::labelReason::label
- ::not_equalReason::not_equal
- ::to_reprReason::to_repr
- ::equalSnapshot::equal
- ::not_equalSnapshot::not_equal
- ::parseSnapshot::parse
- ::to_jsonSnapshot::to_json
- ::to_reprSnapshot::to_repr
- ::equalStallDelta::equal
- ::not_equalStallDelta::not_equal
- ::to_reprStallDelta::to_repr
- ::equalThrottle::equal
- ::not_equalThrottle::not_equal
- ::to_reprThrottle::to_repr
V
budget
V
interval
V
parse_counter
V
parse_cpu_max
V
parse_cpu_stat
V
parse_limit
V
parse_memory_events
V
parse_pressure

moonpressure

Linux cgroup pressure diagnostics, hierarchical admission and worker reservation lifecycle in MoonBit

linux

cgroup

psi

pressure

admission

Download zip

Author

trail-it

Version

0.3.0

License

MIT

Repository

github.com/trail-it/moonpressure

Last updated

6 days ago

Downloads

No dependencies

#Executable API example

The published module is trail-it/moonpressure. This example is compiled as a black-box test.

///|
test "visible ancestor budget" {
  let leaf = @moonpressure.Layer::parse(
    "leaf",
    memory_max="max",
    memory_current="100",
  )
  let parent = @moonpressure.Layer::parse(
    "parent",
    cpu_max="50000 100000",
    memory_max="1000",
    memory_current="900",
  )
  let limits = @moonpressure.budget([leaf, parent])
  assert_eq(limits.quota_cores, Some(0.5))
  assert_eq(limits.hard_headroom_bytes, Some(100L))
}

DeltaError

source

pub(all) suberror DeltaError {
  IdentityChanged
  InvalidInterval
  CounterReset(String)
  AvailabilityChanged(String)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

DeltaError::equal

source

fn DeltaError::equal(DeltaError, DeltaError) -> Bool

DeltaError::not_equal

source

fn DeltaError::not_equal(x : DeltaError, y : DeltaError) -> Bool

DeltaError::to_repr

source

fn DeltaError::to_repr(DeltaError) -> @moonbitlang/core/debug.Repr
Repr

ParseError

source

pub(all) suberror ParseError {
  Invalid(String)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

ParseError::equal

source

fn ParseError::equal(ParseError, ParseError) -> Bool

ParseError::not_equal

source

fn ParseError::not_equal(x : ParseError, y : ParseError) -> Bool

ParseError::to_repr

source

fn ParseError::to_repr(ParseError) -> @moonbitlang/core/debug.Repr
Repr

Admission

source

pub(all) enum Admission {
  Ready
  Shed
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Admission::equal

source

fn Admission::equal(Admission, Admission) -> Bool

Admission::label

source

fn Admission::label(self : Admission) -> String

Admission::not_equal

source

fn Admission::not_equal(x : Admission, y : Admission) -> Bool

Admission::to_repr

source

fn Admission::to_repr(Admission) -> @moonbitlang/core/debug.Repr
Repr

Advice

source

pub struct Advice {
  state : Admission
  reasons : Array[Reason]
  high_streak : Int
  low_streak : Int
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Advice::equal

source

fn Advice::equal(Advice, Advice) -> Bool

Advice::not_equal

source

fn Advice::not_equal(x : Advice, y : Advice) -> Bool

Advice::to_json

source

fn Advice::to_json(self : Advice) -> Json

Advice::to_repr

source

fn Advice::to_repr(Advice) -> @moonbitlang/core/debug.Repr
Repr

Budget

source

pub struct Budget {
  quota_cores : Double?
  hard_headroom_bytes : Int64?
  high_headroom_bytes : Int64?
  quota_source : String?
  hard_source : String?
  high_source : String?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Budget::equal

source

fn Budget::equal(Budget, Budget) -> Bool

Budget::not_equal

source

fn Budget::not_equal(x : Budget, y : Budget) -> Bool

Budget::to_json

source

fn Budget::to_json(self : Budget) -> Json

Budget::to_repr

source

fn Budget::to_repr(Budget) -> @moonbitlang/core/debug.Repr
Repr

Controller

source

pub struct Controller {
  // private fields
}

Controller::new

source

fn Controller::new(policy : Policy) -> Controller

Controller::reset

source

fn Controller::reset(self : Controller) -> Unit

Explicitly reset after a source/generation change. No invalid update mutates state.

Controller::update

source

fn Controller::update(self : Controller, sample : Interval, limits : Budget) -> Advice raise DeltaError

Consume contiguous intervals exactly once. Missing PSI prevents automatic recovery.

CpuMax

source

pub struct CpuMax {
  quota : Limit
  period_us : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

CpuMax::equal

source

fn CpuMax::equal(CpuMax, CpuMax) -> Bool

CpuMax::not_equal

source

fn CpuMax::not_equal(x : CpuMax, y : CpuMax) -> Bool

CpuMax::to_repr

source

fn CpuMax::to_repr(CpuMax) -> @moonbitlang/core/debug.Repr
Repr

CpuStat

source

pub struct CpuStat {
  usage_us : Int64
  throttle : Throttle?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

CpuStat::equal

source

fn CpuStat::equal(CpuStat, CpuStat) -> Bool

CpuStat::not_equal

source

fn CpuStat::not_equal(x : CpuStat, y : CpuStat) -> Bool

CpuStat::to_repr

source

fn CpuStat::to_repr(CpuStat) -> @moonbitlang/core/debug.Repr
Repr

Interval

source

pub struct Interval {
  identity : String
  end_us : Int64
  elapsed_us : Int64
  cpu_cores_used : Double
  throttled_period_percent : Double?
  throttled_us : Int64?
  memory_current_bytes : Int64
  memory_high_events : Int64
  memory_max_events : Int64
  oom_events : Int64
  oom_kills : Int64
  cpu_stall : StallDelta?
  memory_stall : StallDelta?
  io_stall : StallDelta?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Interval::equal

source

fn Interval::equal(Interval, Interval) -> Bool

Interval::not_equal

source

fn Interval::not_equal(x : Interval, y : Interval) -> Bool

Interval::to_json

source

fn Interval::to_json(self : Interval) -> Json

Interval::to_repr

source

fn Interval::to_repr(Interval) -> @moonbitlang/core/debug.Repr
Repr

Layer

source

pub struct Layer {
  name : String
  cpu : CpuMax?
  memory_max : Limit?
  memory_high : Limit?
  memory_current : Int64?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Layer::equal

source

fn Layer::equal(Layer, Layer) -> Bool

Layer::not_equal

source

fn Layer::not_equal(x : Layer, y : Layer) -> Bool

Layer::parse

source

fn Layer::parse(name : String, cpu_max? : String, memory_max? : String, memory_high? : String, memory_current? : String) -> Layer raise ParseError

A visible cgroup layer. Missing controller files are distinct from max.

Layer::to_repr

source

fn Layer::to_repr(Layer) -> @moonbitlang/core/debug.Repr
Repr

Limit

source

pub(all) enum Limit {
  Unlimited
  Finite(Int64)
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Limit::equal

source

fn Limit::equal(Limit, Limit) -> Bool

Limit::not_equal

source

fn Limit::not_equal(x : Limit, y : Limit) -> Bool

Limit::to_repr

source

fn Limit::to_repr(Limit) -> @moonbitlang/core/debug.Repr
Repr

MemoryEvents

source

pub struct MemoryEvents {
  high : Int64
  max : Int64
  oom : Int64
  oom_kill : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

MemoryEvents::equal

source

fn MemoryEvents::equal(MemoryEvents, MemoryEvents) -> Bool

MemoryEvents::not_equal

source

fn MemoryEvents::not_equal(x : MemoryEvents, y : MemoryEvents) -> Bool

MemoryEvents::to_repr

source

fn MemoryEvents::to_repr(MemoryEvents) -> @moonbitlang/core/debug.Repr
Repr

Policy

source

pub struct Policy {
  enter_percent : Double
  exit_percent : Double
  enter_intervals : Int
  exit_intervals : Int
  min_headroom_bytes : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Policy::equal

source

fn Policy::equal(Policy, Policy) -> Bool

Policy::new

source

fn Policy::new(enter_percent? : Double, exit_percent? : Double, enter_intervals? : Int, exit_intervals? : Int, min_headroom_bytes? : Int64) -> Policy raise ParseError

Percent thresholds apply independently to PSI some and throttled periods. These defaults are heuristics; callers tune for their workload.

Policy::not_equal

source

fn Policy::not_equal(x : Policy, y : Policy) -> Bool

Policy::to_repr

source

fn Policy::to_repr(Policy) -> @moonbitlang/core/debug.Repr
Repr

Pressure

source

pub struct Pressure {
  some : PressureLine
  full : PressureLine?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Pressure::equal

source

fn Pressure::equal(Pressure, Pressure) -> Bool

Pressure::not_equal

source

fn Pressure::not_equal(x : Pressure, y : Pressure) -> Bool

Pressure::to_repr

source

fn Pressure::to_repr(Pressure) -> @moonbitlang/core/debug.Repr
Repr

PressureLine

source

pub struct PressureLine {
  avg10 : Double
  avg60 : Double
  avg300 : Double
  total_us : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

PressureLine::equal

source

fn PressureLine::equal(PressureLine, PressureLine) -> Bool

PressureLine::not_equal

source

fn PressureLine::not_equal(x : PressureLine, y : PressureLine) -> Bool

PressureLine::to_repr

source

fn PressureLine::to_repr(PressureLine) -> @moonbitlang/core/debug.Repr
Repr

Reason

source

pub(all) enum Reason {
  CpuStall
  MemoryStall
  IoStall
  CpuThrottled
  LowMemoryHeadroom
  MemoryHigh
  MemoryMax
  OutOfMemory
  Recovering
  MissingPressure
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Reason::equal

source

fn Reason::equal(Reason, Reason) -> Bool

Reason::label

source

fn Reason::label(self : Reason) -> String

Reason::not_equal

source

fn Reason::not_equal(x : Reason, y : Reason) -> Bool

Reason::to_repr

source

fn Reason::to_repr(Reason) -> @moonbitlang/core/debug.Repr
Repr

Snapshot

source

pub struct Snapshot {
  identity : String
  time_us : Int64
  cpu : CpuStat
  memory_current : Int64
  events : MemoryEvents
  cpu_pressure : Pressure?
  memory_pressure : Pressure?
  io_pressure : Pressure?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Snapshot::equal

source

fn Snapshot::equal(Snapshot, Snapshot) -> Bool

Snapshot::not_equal

source

fn Snapshot::not_equal(x : Snapshot, y : Snapshot) -> Bool

Snapshot::parse

source

fn Snapshot::parse(identity : String, time_us : Int64, cpu_stat~ : String, memory_current~ : String, memory_events~ : String, cpu_pressure? : String, memory_pressure? : String, io_pressure? : String) -> Snapshot raise ParseError

Snapshot::to_json

source

fn Snapshot::to_json(self : Snapshot) -> Json

Schema 1 uses decimal strings for Int64 counters to preserve JSON precision.

Snapshot::to_repr

source

fn Snapshot::to_repr(Snapshot) -> @moonbitlang/core/debug.Repr
Repr

StallDelta

source

pub struct StallDelta {
  some_percent : Double
  full_percent : Double?
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

StallDelta::equal

source

fn StallDelta::equal(StallDelta, StallDelta) -> Bool

StallDelta::not_equal

source

fn StallDelta::not_equal(x : StallDelta, y : StallDelta) -> Bool

StallDelta::to_repr

source

fn StallDelta::to_repr(StallDelta) -> @moonbitlang/core/debug.Repr
Repr

Throttle

source

pub struct Throttle {
  periods : Int64
  throttled_periods : Int64
  throttled_us : Int64
} derive(Eq, @moonbitlang/core/debug.Debug
Debug)

Throttle::equal

source

fn Throttle::equal(Throttle, Throttle) -> Bool

Throttle::not_equal

source

fn Throttle::not_equal(x : Throttle, y : Throttle) -> Bool

Throttle::to_repr

source

fn Throttle::to_repr(Throttle) -> @moonbitlang/core/debug.Repr
Repr

budget

source

fn budget(layers : ArrayView[Layer]) -> Budget raise ParseError

Reduces visible layers, including ancestors' own current usage. CPU result is a quota upper bound, not affinity-aware guaranteed capacity.

interval

source

fn interval(old : Snapshot, now : Snapshot) -> Interval raise DeltaError

Only compare the same cgroup generation and a positive <=60s interval.

parse_counter

source

fn parse_counter(text : String) -> Int64 raise ParseError

Strict unsigned decimal in signed Int64 range; rejects signs and overflow.

parse_cpu_max

source

fn parse_cpu_max(text : String) -> CpuMax raise ParseError

parse_cpu_stat

source

fn parse_cpu_stat(text : String) -> CpuStat raise ParseError

parse_limit

source

fn parse_limit(text : String) -> Limit raise ParseError

parse_memory_events

source

fn parse_memory_events(text : String) -> MemoryEvents raise ParseError

parse_pressure

source

fn parse_pressure(text : String) -> Pressure raise ParseError

Source Files

Site source Report issue Packages Build queue Skills Statistics

moonpressure

#Executable API example

#DeltaError

#DeltaError::equal

#DeltaError::not_equal

#DeltaError::to_repr

#ParseError

#ParseError::equal

#ParseError::not_equal

#ParseError::to_repr

#Admission

#Admission::equal

#Admission::label

#Admission::not_equal

#Admission::to_repr

#Advice

#Advice::equal

#Advice::not_equal

#Advice::to_json

#Advice::to_repr

#Budget

#Budget::equal

#Budget::not_equal

#Budget::to_json

#Budget::to_repr

#Controller

#Controller::new

#Controller::reset

#Controller::update

#CpuMax

#CpuMax::equal

#CpuMax::not_equal

#CpuMax::to_repr

#CpuStat

#CpuStat::equal

#CpuStat::not_equal

#CpuStat::to_repr

#Interval

#Interval::equal

#Interval::not_equal

#Interval::to_json

#Interval::to_repr

#Layer

#Layer::equal

#Layer::not_equal

#Layer::parse

#Layer::to_repr

#Limit

#Limit::equal

#Limit::not_equal

#Limit::to_repr

#MemoryEvents

#MemoryEvents::equal

#MemoryEvents::not_equal

#MemoryEvents::to_repr

#Policy

#Policy::equal

#Policy::new

#Policy::not_equal

#Policy::to_repr

#Pressure

#Pressure::equal

#Pressure::not_equal

#Pressure::to_repr

#PressureLine

#PressureLine::equal

#PressureLine::not_equal

#PressureLine::to_repr

#Reason

#Reason::equal

#Reason::label

#Reason::not_equal

#Reason::to_repr

#Snapshot

#Snapshot::equal

#Snapshot::not_equal

#Snapshot::parse

#Snapshot::to_json

#Snapshot::to_repr

#StallDelta

DeltaError

DeltaError::equal

DeltaError::not_equal

DeltaError::to_repr

ParseError

ParseError::equal

ParseError::not_equal

ParseError::to_repr

Admission

Admission::equal

Admission::label

Admission::not_equal

Admission::to_repr

Advice

Advice::equal

Advice::not_equal

Advice::to_json

Advice::to_repr

Budget

Budget::equal

Budget::not_equal

Budget::to_json

Budget::to_repr

Controller

Controller::new

Controller::reset

Controller::update

CpuMax

CpuMax::equal

CpuMax::not_equal

CpuMax::to_repr

CpuStat

CpuStat::equal

CpuStat::not_equal

CpuStat::to_repr

Interval

Interval::equal

Interval::not_equal

Interval::to_json

Interval::to_repr

Layer

Layer::equal

Layer::not_equal

Layer::parse

Layer::to_repr

Limit

Limit::equal

Limit::not_equal

Limit::to_repr

MemoryEvents

MemoryEvents::equal

MemoryEvents::not_equal

MemoryEvents::to_repr

Policy

Policy::equal

Policy::new

Policy::not_equal

Policy::to_repr

Pressure

Pressure::equal

Pressure::not_equal

Pressure::to_repr

PressureLine

PressureLine::equal

PressureLine::not_equal

PressureLine::to_repr

Reason

Reason::equal

Reason::label

Reason::not_equal

Reason::to_repr

Snapshot

Snapshot::equal

Snapshot::not_equal

Snapshot::parse

Snapshot::to_json

Snapshot::to_repr

StallDelta

StallDelta::equal

StallDelta::not_equal