Struct StormConfig 

pub struct StormConfig {
    pub run_id: String,
    pub bead_id: String,
    pub max_queue_depth: usize,
    pub queue_timeout_ms: u64,
    pub fairness_window: usize,
    pub cancel_delay_ms: u64,
}

Tunables for the storm run.

Fields

run_id: String

Correlates every event of this run.

bead_id: String

Owning bead id.

max_queue_depth: usize

Maximum queued jobs before a fail-open job falls back to local.

queue_timeout_ms: u64

Maximum milliseconds a job waits in the queue before timing out.

fairness_window: usize

Fairness lookback window: how many recent placements count toward a worker’s recent-selection penalty.

cancel_delay_ms: u64

Delay before a cancel_when_queued job is cancelled, once queued.

Implementations

impl StormConfig

pub fn new(run_id: impl Into<String>, bead_id: impl Into<String>) -> Self

A reasonable default storm config for the given run/bead ids.

Trait Implementations

impl Clone for StormConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StormConfig

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

Formats the value using the given formatter.

impl Eq for StormConfig

impl PartialEq for StormConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StormConfig