Struct PulseDBSubstrate 

pub struct PulseDBSubstrate { /* private fields */ }

Async adapter wrapping PulseDB for use as a SubstrateProvider.

Each async method delegates to PulseDB’s synchronous API via tokio::task::spawn_blocking, preventing database I/O from blocking the async runtime’s worker threads.

Construction

use std::sync::Arc;
use pulsedb::{PulseDB, Config, PulseDBSubstrate};

let db = Arc::new(PulseDB::open(dir.path().join("a.db"), Config::default())?);
let substrate = PulseDBSubstrate::new(db);

// Or from an owned PulseDB:
let db = PulseDB::open(dir.path().join("b.db"), Config::default())?;
let substrate = PulseDBSubstrate::from_db(db);

Cloning

PulseDBSubstrate implements Clone — cloning is cheap (Arc reference count). Multiple clones share the same underlying database.

Implementations

impl PulseDBSubstrate

pub fn new(db: Arc<PulseDB>) -> Self

Creates a new substrate provider from a shared PulseDB reference.

pub fn from_db(db: PulseDB) -> Self

Creates a new substrate provider, wrapping the given PulseDB in an Arc.

Trait Implementations

impl Clone for PulseDBSubstrate

fn clone(&self) -> PulseDBSubstrate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SubstrateProvider for PulseDBSubstrate

fn store_experience<'life0, 'async_trait>( &'life0 self, exp: NewExperience, ) -> Pin<Box<dyn Future<Output = Result<ExperienceId, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores a new experience and returns its assigned ID.

fn get_experience<'life0, 'async_trait>( &'life0 self, id: ExperienceId, ) -> Pin<Box<dyn Future<Output = Result<Option<Experience>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves an experience by ID, or None if it doesn’t exist.

fn search_similar<'life0, 'life1, 'async_trait>( &'life0 self, collective: CollectiveId, embedding: &'life1 [f32], k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(Experience, f32)>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Searches for experiences similar to the given embedding.

fn get_recent<'life0, 'async_trait>( &'life0 self, collective: CollectiveId, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Experience>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the most recent experiences from a collective.

fn store_relation<'life0, 'async_trait>( &'life0 self, rel: NewExperienceRelation, ) -> Pin<Box<dyn Future<Output = Result<RelationId, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores a relation between two experiences.

fn get_related<'life0, 'async_trait>( &'life0 self, exp_id: ExperienceId, ) -> Pin<Box<dyn Future<Output = Result<Vec<(Experience, ExperienceRelation)>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves all experiences related to the given experience (both directions).

fn store_insight<'life0, 'async_trait>( &'life0 self, insight: NewDerivedInsight, ) -> Pin<Box<dyn Future<Output = Result<InsightId, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores a derived insight synthesized from source experiences.

fn get_insights<'life0, 'life1, 'async_trait>( &'life0 self, collective: CollectiveId, embedding: &'life1 [f32], k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(DerivedInsight, f32)>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Searches for insights similar to the given embedding.

fn get_activities<'life0, 'async_trait>( &'life0 self, collective: CollectiveId, ) -> Pin<Box<dyn Future<Output = Result<Vec<Activity>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves active (non-stale) agent activities in a collective.

fn get_context_candidates<'life0, 'async_trait>( &'life0 self, request: ContextRequest, ) -> Pin<Box<dyn Future<Output = Result<ContextCandidates, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Assembles context candidates from all retrieval primitives.

fn watch<'life0, 'async_trait>( &'life0 self, collective: CollectiveId, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = WatchEvent> + Send>>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribes to real-time experience change events in a collective.

fn create_collective<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CollectiveId, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Creates a new collective (namespace).

fn get_or_create_collective<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<CollectiveId, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets an existing collective by name, or creates it if it doesn’t exist.

fn list_collectives<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Collective>, PulseDBError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists all collectives in the database.