Struct ResourceGovernor 

pub struct ResourceGovernor { /* private fields */ }

Process/engine resource governor.

Implementations

impl ResourceGovernor

pub fn try_new(config: GovernorConfig) -> Result<Self>

Build a governor after validating config (JOE-1917).

pub fn new(config: GovernorConfig) -> Self

Build a governor. Panics if config fails validation. Prefer Self::try_new at public SDK boundaries.

pub fn config(&self) -> &GovernorConfig

pub fn process_global() -> Arc<Self>

Process-wide default governor (desktop profile).

Isolated engines can construct their own ResourceGovernor instead.

pub fn acquire( self: &Arc<Self>, kind: PermitKind, ctx: Option<&OpContext>, ) -> Result<ResourcePermit>

Acquire a single permit, optionally waiting with cancel/deadline.

pub fn acquire_stt( self: &Arc<Self>, cpu_threads: usize, memory: u64, ctx: Option<&OpContext>, ) -> Result<ResourcePermit>

Acquire STT permit + blocking permit + CPU thread budget (+ optional memory).

Acquisition order is fixed (memory → STT → blocking → CPU) under a brief mutex so concurrent multi-resource acquires cannot deadlock. The mutex is not held across sleep/wait.

pub fn acquire_tts( self: &Arc<Self>, memory: u64, ctx: Option<&OpContext>, ) -> Result<ResourcePermit>

Acquire local TTS + blocking permits (+ optional memory).

pub fn recommend_stt_threads(&self) -> usize

How many Whisper threads a new STT job should use given remaining budget.

pub fn stats(&self) -> GovernorStats

Trait Implementations

impl Default for ResourceGovernor

fn default() -> Self

Returns the “default value” for a type.