Struct WorkerSupervisionConfig 

pub struct WorkerSupervisionConfig {
    pub restart_backoff_initial_ms: Option<u64>,
    pub restart_backoff_max_ms: Option<u64>,
    pub restart_backoff_multiplier: Option<u32>,
    pub restart_window_ms: Option<u64>,
    pub max_restarts_per_window: Option<u32>,
    pub stop_grace_ms: Option<u64>,
}

Managed-worker supervision settings from [worker_supervision].

Fields

restart_backoff_initial_ms: Option<u64>

Delay before the first restart in a window, milliseconds.

restart_backoff_max_ms: Option<u64>

Ceiling the geometric backoff is clamped to, milliseconds.

restart_backoff_multiplier: Option<u32>

Geometric growth factor per restart already made in the window.

restart_window_ms: Option<u64>

Sliding window over which restarts are counted, milliseconds.

max_restarts_per_window: Option<u32>

Restarts permitted within one window before an instance is failed.

stop_grace_ms: Option<u64>

Grace given to each of SIGTERM and SIGKILL when stopping a managed worker’s process group, milliseconds.

Implementations

impl WorkerSupervisionConfig

pub fn resolve(self) -> Result<Option<SupervisionPolicy>, ServerError>

Resolve the section into a policy.

Ok(None) is the honest reading of an ENTIRELY absent section: the operator has not commissioned supervision, and the managed-worker surface refuses with the remedy rather than inventing numbers.

Errors

Returns ServerError::Config naming every missing key for a PARTIAL section, and naming the offending key for a value that cannot express a working discipline (a zero interval, a zero budget, a shrinking backoff, or a ceiling below the initial delay).

Trait Implementations

impl Clone for WorkerSupervisionConfig

fn clone(&self) -> WorkerSupervisionConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for WorkerSupervisionConfig

impl Debug for WorkerSupervisionConfig

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

Formats the value using the given formatter.

impl Default for WorkerSupervisionConfig

fn default() -> WorkerSupervisionConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WorkerSupervisionConfig

where WorkerSupervisionConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for WorkerSupervisionConfig

impl PartialEq for WorkerSupervisionConfig

fn eq(&self, other: &WorkerSupervisionConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for WorkerSupervisionConfig