Struct PolicyMemory 

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

Applies a policy to loaded history, propagating backend and policy errors unchanged. Append and clear operations delegate to the backend.

Example

use rig_memory::{InMemoryConversationMemory, PolicyMemory, SlidingWindowMemory};

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

Implementations

impl<M, P> PolicyMemory<M, P>

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

Wrap inner so every loaded history is run through policy.

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 into_inner(self) -> (M, P)

Consume the wrapper and return the underlying backend and policy.

Trait Implementations

impl<M: Clone, P: Clone> Clone for PolicyMemory<M, P>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M, P> ConversationMemory for PolicyMemory<M, P>

where M: ConversationMemory, P: MemoryPolicy,

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: Copy, P: Copy> Copy for PolicyMemory<M, P>

impl<M: Debug, P: Debug> Debug for PolicyMemory<M, P>

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

Formats the value using the given formatter.