class

HT2::AdaptiveFlowControl

Inherits Reference < Object

Adaptive flow control manager that dynamically adjusts window update strategies based on data consumption patterns and network conditions

Constructors

new(initial_window_size : Int64, strategy : Strategy = Strategy::MODERATE)
Source

Instance methods

adapt_strategy(rtt_ms : Float64 | Nil = nil, loss_rate : Float64 | Nil = nil) : Nil

Update flow control strategy based on network conditions

Source
calculate_increment(current_window : Int64, consumed : Int64) : Int32

Calculate optimal window increment based on consumption patterns

Source
current_threshold
Source
current_threshold=(current_threshold : Float64)
Source
initial_window_size
Source
initial_window_size=(initial_window_size : Int64)
Source
max_update_threshold
Source
max_update_threshold=(max_update_threshold : Float64)
Source
metrics
Source
metrics=(metrics : FlowMetrics)
Source
min_update_threshold
Source
min_update_threshold=(min_update_threshold : Float64)
Source
needs_update?(current_window : Int64, available_window : Int64) : Bool

Check if window update is needed based on current window size

Source
record_stall

Record that window hit zero (stalled)

Source
strategy
Source

Nested types