Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

In-memory backend storing adaptive state in process-local hash maps.

This backend is primarily useful for tests, examples, or deployments where adaptive state does not need to survive process restarts.

Implementations

impl InMemoryBackend

pub fn new() -> Self

Create an empty in-memory backend.

Returns

A new InMemoryBackend with empty storage maps.

Trait Implementations

impl Default for InMemoryBackend

fn default() -> Self

Returns the “default value” for a type.

impl StorageBackend for InMemoryBackend

fn store_run( &self, record: &RunRecord, ) -> impl Future<Output = Result<()>> + Send

Persist one observed run.

fn load_plan( &self, agent_id: &str, ) -> impl Future<Output = Result<Option<ExecutionPlan>>> + Send

Load the current execution plan for an agent.

fn list_runs( &self, agent_id: &str, ) -> impl Future<Output = Result<Vec<RunRecord>>> + Send

List stored runs for an agent.

impl StorageBackendDyn for InMemoryBackend

fn store_run_dyn<'a>( &'a self, record: &'a RunRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Persist one observed run.

fn load_plan_dyn<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<ExecutionPlan>>> + Send + 'a>>

Load the current execution plan for an agent.

fn list_runs_dyn<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunRecord>>> + Send + 'a>>

List stored runs for an agent.

fn store_trie<'a>( &'a self, agent_id: &'a str, envelope: &'a TrieEnvelope, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Persist a serialized prediction trie for an agent.

fn load_trie<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<TrieEnvelope>>> + Send + 'a>>

Load the serialized prediction trie for an agent.

fn store_accumulators<'a>( &'a self, agent_id: &'a str, state: &'a AccumulatorState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Persist trie accumulator state for an agent.

fn load_accumulators<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<AccumulatorState>>> + Send + 'a>>

Load trie accumulator state for an agent.

fn store_plan(&self, plan: &ExecutionPlan) -> Result<()>

Persist an execution plan for an agent.

fn store_observations<'a>( &'a self, agent_id: &'a str, observations: &'a [PromptIR], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Persist prompt IR observations for an agent or derived Adaptive Cache Governor (ACG) profile.

fn load_observations<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<PromptIR>>>> + Send + 'a>>

Load prompt IR observations for an agent or derived Adaptive Cache Governor (ACG) profile.

fn store_stability<'a>( &'a self, agent_id: &'a str, result: &'a StabilityAnalysisResult, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Persist an ACG stability result for an agent or derived profile.

fn load_stability<'a>( &'a self, agent_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<StabilityAnalysisResult>>> + Send + 'a>>

Load an ACG stability result for an agent or derived profile.