pub struct SqliteDatabase { /* private fields */ }Expand description
SQLite database implementation
Implementations§
Source§impl SqliteDatabase
impl SqliteDatabase
pub async fn new(config: DatabaseConfig) -> DatabaseResult<Self>
Trait Implementations§
Source§impl Database for SqliteDatabase
impl Database for SqliteDatabase
Source§fn health_check<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn health_check<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Check database health
Source§fn initialize<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn initialize<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Initialize database schema
Source§fn store_consciousness_state<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 ConsciousnessState,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn store_consciousness_state<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 ConsciousnessState,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Store consciousness state
Source§fn get_consciousness_history<'life0, 'life1, 'async_trait>(
&'life0 self,
agent_id: &'life1 str,
limit: usize,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<ConsciousnessState>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_consciousness_history<'life0, 'life1, 'async_trait>(
&'life0 self,
agent_id: &'life1 str,
limit: usize,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<ConsciousnessState>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Get consciousness history for an agent
Source§fn store_ripple<'life0, 'life1, 'async_trait>(
&'life0 self,
ripple: &'life1 ConsciousnessRipple,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn store_ripple<'life0, 'life1, 'async_trait>(
&'life0 self,
ripple: &'life1 ConsciousnessRipple,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Store consciousness ripple
Source§fn get_ripples<'life0, 'async_trait>(
&'life0 self,
start: DateTime<Utc>,
end: DateTime<Utc>,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<ConsciousnessRipple>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_ripples<'life0, 'async_trait>(
&'life0 self,
start: DateTime<Utc>,
end: DateTime<Utc>,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<ConsciousnessRipple>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get ripples by time range
Source§fn store_task<'life0, 'life1, 'async_trait>(
&'life0 self,
task: &'life1 Task,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn store_task<'life0, 'life1, 'async_trait>(
&'life0 self,
task: &'life1 Task,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Store task
Source§fn store_task_result<'life0, 'life1, 'async_trait>(
&'life0 self,
result: &'life1 TaskResult,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn store_task_result<'life0, 'life1, 'async_trait>(
&'life0 self,
result: &'life1 TaskResult,
) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Update task result
Source§fn get_pending_tasks<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<Task>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_pending_tasks<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<Task>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Get pending tasks
Source§fn vector_search<'life0, 'life1, 'async_trait>(
&'life0 self,
embedding: &'life1 [f32],
limit: usize,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<VectorSearchResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn vector_search<'life0, 'life1, 'async_trait>(
&'life0 self,
embedding: &'life1 [f32],
limit: usize,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<VectorSearchResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Vector search for consciousness embeddings
Source§fn hybrid_search<'life0, 'async_trait>(
&'life0 self,
query: HybridSearchQuery,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<HybridSearchResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn hybrid_search<'life0, 'async_trait>(
&'life0 self,
query: HybridSearchQuery,
) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<HybridSearchResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Hybrid search combining vector and structured queries
Auto Trait Implementations§
impl !RefUnwindSafe for SqliteDatabase
impl !UnwindSafe for SqliteDatabase
impl Freeze for SqliteDatabase
impl Send for SqliteDatabase
impl Sync for SqliteDatabase
impl Unpin for SqliteDatabase
impl UnsafeUnpin for SqliteDatabase
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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