do-memory-core 0.1.30

Core episodic learning system for AI agents with pattern extraction, reward scoring, and dual storage backend
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! # Pattern Extraction Queue
//!
//! Asynchronous queue system for pattern extraction from completed episodes.
//!
//! Episodes are enqueued when completed, and a pool of worker tasks processes
//! them in parallel without blocking the main completion flow.
//!
//! ## Example
//!
//! ```no_run
//! use do_memory_core::learning::queue::{PatternExtractionQueue, QueueConfig};
//! use do_memory_core::memory::SelfLearningMemory;
//! use std::sync::Arc;
//!
//! #[tokio::main]
//! async fn main() {
//!     let memory = Arc::new(SelfLearningMemory::new());
//!     let config = QueueConfig::default();
//!     let queue = PatternExtractionQueue::new(config, memory);
//!
//!     // Start worker pool
//!     queue.start_workers().await;
//!
//!     // Workers now process episodes in background
//! }
//! ```
//!

pub mod operations;
#[cfg(test)]
pub mod tests;
pub mod types;

pub use operations::PatternExtractionQueue;
pub use types::QueueConfig;
pub use types::QueueStats;