Struct InMemoryGarrison 

pub struct InMemoryGarrison { /* private fields */ }

Thread-safe in-memory Garrison implementation.

Stores all entries in memory using a VecDeque protected by an RwLock for concurrent access. All data is lost when the process terminates; use SqliteGarrison (feature sqlite) when persistence is required.

Examples

use paladin_memory::garrison::InMemoryGarrison;
use paladin_core::platform::container::garrison::GarrisonConfig;
use paladin_ports::output::garrison_port::GarrisonPort;
use paladin_core::platform::container::garrison::{GarrisonEntry, ConversationRole};

#[tokio::main]
async fn main() {
    let config = GarrisonConfig::default();
    let garrison = InMemoryGarrison::new(config);

    // Store an entry
    let entry = GarrisonEntry::new(
        ConversationRole::User,
        "Hello!".to_string()
    );
    garrison.remember(entry).await.unwrap();

    // Retrieve it
    let recent = garrison.recall_recent(10).await.unwrap();
    assert_eq!(recent.len(), 1);
}

Implementations

impl InMemoryGarrison

pub fn new(config: GarrisonConfig) -> Self

Creates a new in-memory Garrison with the given configuration.

Arguments

• config - Configuration for windowing and eviction behavior

Examples

use paladin_memory::garrison::InMemoryGarrison;
use paladin_core::platform::container::garrison::GarrisonConfig;

let config = GarrisonConfig::new(100, Some(4000));
let garrison = InMemoryGarrison::new(config);

Trait Implementations

impl GarrisonPort for InMemoryGarrison

fn remember<'life0, 'async_trait>( &'life0 self, entry: GarrisonEntry, ) -> Pin<Box<dyn Future<Output = Result<(), GarrisonError>> + Send + 'async_trait>>

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

Stores a new entry in the Garrison

fn recall_recent<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<GarrisonEntry>, GarrisonError>> + Send + 'async_trait>>

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

Retrieves the N most recent entries

fn search<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<GarrisonEntry>, GarrisonError>> + Send + 'async_trait>>

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

Searches for entries matching a text query

fn forget_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), GarrisonError>> + Send + 'async_trait>>

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

Clears all entries from the Garrison

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<GarrisonStats, GarrisonError>> + Send + 'async_trait>>

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

Returns statistics about the current state of the Garrison