Skip to main content

Crate klieo_graph_projector

Crate klieo_graph_projector 

Source
Expand description

klieo-graph-projector — continuous-learning bridge from klieo_core::memory::EpisodicMemory to klieo_memory_graph::KnowledgeGraph.

Two entry points:

  • ProjectableEpisodic — drop-in wrapper around any Arc<dyn EpisodicMemory> that broadcasts each recorded (RunId, Episode) pair on a tokio::sync::broadcast channel. The wrapped store is the single source of truth; the broadcast is a side-effect for subscribers and never causes record() to fail.
  • EpisodeProjector — broadcast subscriber that translates each episode into typed entities (via an klieo_memory_graph::EntityExtractor) and writes MENTIONED_IN edges into a klieo_memory_graph::KnowledgeGraph. Also offers project_run() for on-demand batch replay of historical episodes.

Stable at 1.x. Trait freeze contract recorded in ADR-039.

Re-exports§

pub use error::ProjectionError;
pub use extractors::HintsOnlyExtractor;
pub use projectable::ProjectableEpisodic;
pub use projector::EpisodeProjector;
pub use projector::EpisodeProjectorBuilder;
pub use rules::entities_for_episode;

Modules§

error
Typed error returned by crate::EpisodeProjector operations.
extractors
EntityExtractor impls bundled with the projector.
projectable
EpisodicMemory wrapper that broadcasts every recorded (RunId, Episode) pair on a tokio::sync::broadcast channel.
projector
EpisodeProjector — broadcast subscriber that translates each recorded Episode into typed entities and indexes them into a KnowledgeGraph.
rules
Static rules that map each Episode variant to a hint set of EntityRefs suitable for indexing into a klieo_memory_graph::KnowledgeGraph.