machi-compaction 1.0.0

Conversation compaction strategies for the Machi kernel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! Compaction strategy trait.

use machi_types::{MachiError, Message};

/// Result of a compaction pass.
#[derive(Debug, Clone)]
pub struct CompactionOutcome {
    /// Messages after compaction.
    pub messages: Vec<Message>,
    /// True when the list changed.
    pub changed: bool,
    /// Strategy name for metrics.
    pub strategy: &'static str,
}

/// Pure compaction strategy.
pub trait CompactionStrategy: Send + Sync {
    /// Stable strategy id (`max_messages`, `token_threshold`, …).
    fn name(&self) -> &'static str;

    /// Whether compaction should run given current size estimates.
    fn should_compact(&self, messages: &[Message], token_estimate: u64) -> bool;

    /// Produce a compacted message list.
    ///
    /// # Errors
    ///
    /// Returns typed compaction failures (should not panic on normal input).
    fn compact(&self, messages: Vec<Message>) -> Result<CompactionOutcome, MachiError>;
}