Struct EffectiveConstraints 

pub struct EffectiveConstraints {
    pub max_concurrent_dispatchers: EffectiveCeiling,
    pub max_message_rate: Option<EffectiveCeiling>,
    pub max_message_rate_declared: Option<String>,
    pub max_connection_rate: Option<EffectiveCeiling>,
    pub max_source_selection_rate: Option<EffectiveCeiling>,
}

Steady-state ceilings implied by an EgressPathConfig. Each ceiling carries a tag for which configuration term produced it.

{{since(‘dev’)}}

These are per-queue ceilings; shared limits in additional_* maps are reported at their full value and may be tighter in practice when the bucket is contended.

Fields

max_concurrent_dispatchers: EffectiveCeiling

max_message_rate: Option<EffectiveCeiling>

None when neither max_message_rate nor any additional_message_rate_throttles entry nor max_connection_rate is configured.

max_message_rate_declared: Option<String>

Pre-formatted display of the declared max_message_rate when a different term (typically ReconnectCycling) wins the minimum. Lets renderers show a “declared but unreachable” annotation. Uses the operator’s original units.

max_connection_rate: Option<EffectiveCeiling>

max_source_selection_rate: Option<EffectiveCeiling>

Implementations

impl EffectiveConstraints

pub fn render(&self, out: &mut dyn Write) -> Result

Render a human-readable multi-line block. The same formatting is used by kcli inspect-ready-q and by the resolve-shaping-domain script, so operators see the same output regardless of where they retrieved the config.

pub fn to_human_string(&self) -> String

pub fn merge(&mut self, other: &EffectiveConstraints)

Fold another EffectiveConstraints into this one by taking the per-axis minimum. The losing ceiling is shadowed; the winner’s source tag is preserved. The max_message_rate_declared annotation is re-evaluated so a rate that is now shadowed by an external source gets the “declared but unreachable” treatment.

Trait Implementations

impl Clone for EffectiveConstraints

fn clone(&self) -> EffectiveConstraints

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ComposeSchema for EffectiveConstraints

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl Debug for EffectiveConstraints

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EffectiveConstraints

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for EffectiveConstraints

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for EffectiveConstraints

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToSchema for EffectiveConstraints

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference [utoipa::openapi::schema::Schema]s for this type.

impl StructuralPartialEq for EffectiveConstraints