Skip to main content

FactStore

Struct FactStore 

Source
pub struct FactStore { /* private fields */ }
Expand description

Manages facts for one agent across all actors.

Implementations§

Source§

impl FactStore

Source

pub fn new( storage: Arc<dyn AgentStorage>, agent_id: String, config: FactsConfig, ) -> FactStore

Source

pub async fn add_facts( &self, actor_id: &str, facts: Vec<KeyFact>, ) -> Result<Vec<KeyFact>, AgentError>

Add new facts for an actor, enforcing max_facts by evicting lowest priority rows. Returns the authoritative post-write set of facts for the actor so callers can refresh their cache without re-reading from storage.

Source

pub async fn get_facts( &self, actor_id: &str, ) -> Result<Vec<KeyFact>, AgentError>

Load all facts for an actor.

Source

pub async fn get_facts_by_category( &self, actor_id: &str, category: &FactCategory, ) -> Result<Vec<KeyFact>, AgentError>

Load facts filtered by category.

Source

pub async fn query( &self, filter: &FactFilter, ) -> Result<Vec<KeyFact>, AgentError>

Query facts across actors.

Source

pub async fn delete_fact( &self, actor_id: &str, fact_id: &str, ) -> Result<(), AgentError>

Delete a specific fact.

Source

pub async fn delete_actor_data(&self, actor_id: &str) -> Result<(), AgentError>

Delete all data for an actor (facts + sessions). Privacy compliance.

Source

pub fn format_for_context(&self, facts: &[KeyFact], max_tokens: usize) -> String

Format facts as a string for chat-time system prompt injection.

Output is a plain bulleted list of fact statements, ordered by priority, truncated to fit max_tokens. Category labels and confidence scores are intentionally omitted because they look like metadata noise to the chat LLM and have caused the model to hedge (“I don’t know your identity”) even when the facts clearly state the user’s name.

Use the extractor’s separate prompt format when feeding facts back into the fact extractor for dedup guidance.

Source

pub fn agent_id(&self) -> &str

Get the agent ID this store manages.

Source

pub fn config(&self) -> &FactsConfig

Get the underlying config.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

Source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more