Struct SlidingWindowMemory 

pub struct SlidingWindowMemory { /* private fields */ }

Wraps any Memory and limits the stored history to the last max_messages non-system entries (always preserving a leading system message in addition to that limit).

Implementations

impl SlidingWindowMemory

pub fn new( inner: Arc<dyn Memory>, max_messages: usize, ) -> Result<Self, AppError>

Create a sliding-window wrapper.

max_messages is the number of non-system messages to retain and must be at least 1.

Trait Implementations

impl Memory for SlidingWindowMemory

fn load<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load all messages for a session.

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, messages: &'life2 [Message], ) -> Pin<Box<dyn Future<Output = Result<(), AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Replace the entire message list for a session.

fn append<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, messages: &'life2 [Message], ) -> Pin<Box<dyn Future<Output = Result<(), AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append messages to an existing session (creating it if needed).

fn clear<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), AppError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove all messages for a session.