Struct CompactionState 

pub struct CompactionState { /* private fields */ }

压缩运行时状态 — 跟踪熔断器与防重复触发。

由 Session 持有，在 Agent loop 期间维护。

Examples

use katu_agent::compaction::CompactionState;

let mut state = CompactionState::new();
assert!(!state.is_circuit_broken(3));

state.record_failure();
state.record_failure();
state.record_failure();
assert!(state.is_circuit_broken(3));

state.record_success();
assert!(!state.is_circuit_broken(3));

Implementations

impl CompactionState

pub fn new() -> Self

创建初始状态。

pub fn record_success(&mut self)

记录一次压缩成功 — 重置熔断器。

pub fn record_failure(&mut self)

记录一次压缩失败 — 递增熔断器计数。

pub fn is_circuit_broken(&self, max_failures: u32) -> bool

熔断器是否已触发。

max_failures == 0 表示不限制。

pub fn mark_compacted(&mut self, step: u32, tokens_after: Option<u64>)

标记当前步已执行压缩。

pub fn already_compacted_at(&self, step: u32) -> bool

检查指定步是否已执行过压缩（防重复）。

pub fn consecutive_failures(&self) -> u32

连续失败次数。

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

上次压缩后的 token 数。

pub fn reset(&mut self)

重置（用于 session 恢复等场景）。

Trait Implementations

impl Clone for CompactionState

fn clone(&self) -> CompactionState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompactionState

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

Formats the value using the given formatter.

impl Default for CompactionState

fn default() -> Self

Returns the “default value” for a type.