Struct ObservedMemory 

pub struct ObservedMemory<M> { /* private fields */ }

Wraps any ConversationMemory and emits a context.sampled event on every load. append and clear pass through unchanged.

Example

use rig::memory::InMemoryConversationMemory;
use rig_tap::ObservedMemory;

let inner = InMemoryConversationMemory::new();
let observed = ObservedMemory::new(inner);
// pass `observed` to `agent.memory(observed)`

Implementations

impl<M> ObservedMemory<M>

pub fn new(inner: M) -> Self

Wrap inner so its loads emit context.sampled events.

pub fn inner(&self) -> &M

Return a reference to the wrapped memory.

pub fn into_inner(self) -> M

Consume the decorator and return the wrapped memory.

Trait Implementations

impl<M> Clone for ObservedMemory<M>

where M: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M> ConversationMemory for ObservedMemory<M>

where M: ConversationMemory,

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

Load the full conversation history for conversation_id.

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

Append messages to the conversation identified by conversation_id.

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

Remove all stored messages for conversation_id.

impl<M> Debug for ObservedMemory<M>

where M: Debug,

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

Formats the value using the given formatter.