Struct DemotingPolicyMemory 

pub struct DemotingPolicyMemory<M, P, H> { /* private fields */ }

Applies a policy and delivers newly demoted prefixes to a hook before returning retained history. The policy must report demotions through MemoryPolicy::apply_with_demoted.

Only one delivery per tracked conversation runs at a time. Concurrent loads return retained history immediately without waiting for the hook, so success does not guarantee durable demotion. Hook errors reach only the delivering caller; unchanged watermarks allow later loads to retry.

Watermarks are process-local. Hooks must tolerate redelivery after restarts, cancellation, or discarded tracking state, following DemotionHook.

use rig_memory::{
    DemotingPolicyMemory, DemotionHook, InMemoryConversationMemory,
    MemoryError, NoopDemotionHook, SlidingWindowMemory,
};

let memory = DemotingPolicyMemory::new(
    InMemoryConversationMemory::new(),
    SlidingWindowMemory::last_messages(20),
    NoopDemotionHook,
);

Implementations

impl<M, P, H> DemotingPolicyMemory<M, P, H>

pub fn new(inner: M, policy: P, hook: H) -> Self

Wrap inner so every load runs through policy and demoted messages flow into hook.

impl<M, P, H> DemotingPolicyMemory<M, P, H>

pub fn inner(&self) -> &M

Return a reference to the wrapped backend.

pub fn policy(&self) -> &P

Return a reference to the wrapped policy.

pub fn hook(&self) -> &H

Return a reference to the third component.

pub fn into_inner(self) -> (M, P, H)

Consume the wrapper and return its three components.

pub fn forget(&self, conversation_id: &ConversationId)

Drop the in-process state for conversation_id.

Entries otherwise persist for the wrapper’s lifetime. Does nothing if the state lock is poisoned. In-flight work is not cancelled.

pub fn tracked_conversations(&self) -> usize

Number of conversations currently tracked in the state map. Useful for telemetry and leak detection. Returns 0 if the internal state lock is poisoned.

Trait Implementations

impl<M, P, H> ConversationMemory for DemotingPolicyMemory<M, P, H>

where M: ConversationMemory, P: MemoryPolicy, H: DemotionHook,

fn load<'a>( &'a self, conversation_id: &'a ConversationId, ) -> WasmBoxedFuture<'a, Result<Vec<Message>, MemoryError>>

Load the full conversation history for conversation_id.

fn append<'a>( &'a self, conversation_id: &'a ConversationId, messages: Vec<Message>, ) -> WasmBoxedFuture<'a, Result<(), MemoryError>>

Append messages to the conversation identified by conversation_id.

fn clear<'a>( &'a self, conversation_id: &'a ConversationId, ) -> WasmBoxedFuture<'a, Result<(), MemoryError>>

Remove all stored messages for conversation_id.

impl<M, P, H> Debug for DemotingPolicyMemory<M, P, H>

where M: Debug, P: Debug,

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

Formats the value using the given formatter.