Struct ResizeCoalescer 

pub struct ResizeCoalescer { /* private fields */ }

Adaptive resize stream coalescer.

Implements latest-wins coalescing with regime-aware behavior.

Implementations

impl ResizeCoalescer

pub fn new(config: CoalescerConfig, initial_size: (u16, u16)) -> Self

Create a new coalescer with the given configuration and initial size.

pub fn with_telemetry_hooks(self, hooks: TelemetryHooks) -> Self

Attach telemetry hooks for external observability.

pub fn with_evidence_sink(self, sink: EvidenceSink) -> Self

Attach an evidence sink for JSONL decision logs.

pub fn with_evidence_run_id(self, run_id: impl Into<String>) -> Self

Set the run identifier used in evidence logs.

pub fn with_screen_mode(self, screen_mode: ScreenMode) -> Self

Set the screen mode label used in evidence logs.

pub fn set_evidence_sink(&mut self, sink: Option<EvidenceSink>)

Set or clear the evidence sink.

pub fn with_last_render(self, time: Instant) -> Self

Set the last render time (for deterministic testing).

pub fn record_external_apply(&mut self, width: u16, height: u16, now: Instant)

Record an externally-applied resize (immediate path).

pub fn regime_transition_count(&self) -> u64

Get current regime transition count.

pub fn cycle_time_percentiles(&self) -> Option<CycleTimePercentiles>

Get cycle time percentiles (p50, p95, p99) in milliseconds. Returns None if no cycle times recorded.

pub fn handle_resize(&mut self, width: u16, height: u16) -> CoalesceAction

Handle a resize event.

Returns the action to take immediately.

pub fn handle_resize_at( &mut self, width: u16, height: u16, now: Instant, ) -> CoalesceAction

Handle a resize event at a specific time (for testing).

pub fn tick(&mut self) -> CoalesceAction

Tick the coalescer (call each frame).

Returns the action to take.

pub fn tick_at(&mut self, now: Instant) -> CoalesceAction

Tick at a specific time (for testing).

pub fn time_until_apply(&self, now: Instant) -> Option<Duration>

Time until the pending resize should be applied.

pub fn has_pending(&self) -> bool

Check if there’s a pending resize.

pub fn regime(&self) -> Regime

Get the current regime.

pub fn bocpd_enabled(&self) -> bool

Check if BOCPD-based regime detection is enabled.

pub fn bocpd(&self) -> Option<&BocpdDetector>

Get the BOCPD detector for inspection (if enabled).

Returns None if BOCPD is not enabled.

pub fn bocpd_p_burst(&self) -> Option<f64>

Get the current P(burst) from BOCPD (if enabled).

Returns the posterior probability that the system is in burst regime. Returns None if BOCPD is not enabled.

pub fn bocpd_recommended_delay(&self) -> Option<u64>

Get the recommended delay from BOCPD (if enabled).

Returns the recommended coalesce delay in milliseconds based on the current posterior distribution. Returns None if BOCPD is not enabled.

pub fn event_rate(&self) -> f64

Get the current event rate (events/second).

pub fn last_applied(&self) -> (u16, u16)

Get the last applied size.

pub fn logs(&self) -> &[DecisionLog]

Get decision logs (if logging enabled).

pub fn clear_logs(&mut self)

Clear decision logs.

pub fn stats(&self) -> CoalescerStats

Get statistics about the coalescer.

pub fn decision_logs_jsonl(&self) -> String

Export decision logs as JSONL (one entry per line).

pub fn decision_checksum(&self) -> u64

Compute a deterministic checksum of decision logs.

pub fn decision_checksum_hex(&self) -> String

Compute checksum as hex string.

pub fn decision_summary(&self) -> DecisionSummary

Compute a summary of the decision log.

pub fn evidence_to_jsonl(&self) -> String

Export config + decision logs + summary as JSONL.

Trait Implementations

impl Debug for ResizeCoalescer

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

Formats the value using the given formatter.