Struct FlowControlPolicy 

pub struct FlowControlPolicy {
    pub config: FlowControlConfig,
}

Deterministic policy evaluator for websocket remote flow control.

Fields

config: FlowControlConfig

Runtime policy configuration.

Implementations

impl FlowControlPolicy

pub const fn new(config: FlowControlConfig) -> Self

Construct a policy with explicit configuration.

pub fn evaluate(self, snapshot: FlowControlSnapshot) -> FlowControlDecision

Evaluate one deterministic backpressure decision.

pub fn should_replenish( self, consumed_bytes: u32, window_bytes: u32, elapsed_ms: u64, ) -> bool

Replenish flow-control window at 50% consumption or interval timeout.

pub fn should_drop_input_event( self, queue_bytes: u32, class: InputEventClass, ) -> bool

Non-negotiable input drop rule: only non-interactive events are droppable.

Trait Implementations

impl Clone for FlowControlPolicy

fn clone(&self) -> FlowControlPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowControlPolicy

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

Formats the value using the given formatter.

impl Default for FlowControlPolicy

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for FlowControlPolicy

fn eq(&self, other: &FlowControlPolicy) -> 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 Copy for FlowControlPolicy

impl StructuralPartialEq for FlowControlPolicy