Struct AgentDBClient 

pub struct AgentDBClient { /* private fields */ }

Implementations

impl AgentDBClient

pub fn new(base_url: String) -> Self

pub fn with_api_key(self, api_key: String) -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub async fn insert<T: Serialize>( &self, collection: &str, id: &[u8], embedding: &[f32], metadata: Option<&T>, ) -> Result<InsertResponse>

Insert single document

pub async fn batch_insert<T: Serialize>( &self, collection: &str, documents: Vec<BatchDocument<T>>, ) -> Result<BatchInsertResponse>

Batch insert documents

pub async fn vector_search<T: DeserializeOwned>( &self, query: VectorQuery, ) -> Result<Vec<T>>

Vector similarity search

pub async fn metadata_search<T: DeserializeOwned>( &self, query: MetadataQuery, ) -> Result<Vec<T>>

Metadata-only search

pub async fn get<T: DeserializeOwned>( &self, collection: &str, id: &[u8], ) -> Result<Option<T>>

Get document by ID

pub async fn delete(&self, collection: &str, id: &[u8]) -> Result<()>

Delete document

pub async fn create_collection(&self, config: CollectionConfig) -> Result<()>

Create collection

pub async fn health_check(&self) -> Result<HealthResponse>

Health check

impl AgentDBClient

Query templates for common operations

pub async fn find_similar_conditions( &self, current: &Observation, k: usize, time_window_hours: Option<i64>, ) -> Result<Vec<Observation>>

Find similar market conditions Target: <1ms for k=10

pub async fn get_signals_by_strategy( &self, strategy_id: &str, min_confidence: f64, limit: usize, ) -> Result<Vec<Signal>>

Get signals by strategy Target: <1ms

pub async fn find_similar_decisions( &self, signal: &Signal, k: usize, ) -> Result<Vec<Signal>>

Find similar trading decisions Target: <1ms for k=10

pub async fn get_top_strategies( &self, min_score: f64, limit: usize, ) -> Result<Vec<(String, f64)>>

Get top performing strategies Target: <50ms for 1000 traces

pub async fn get_observations_in_range( &self, symbol: &str, start_us: i64, end_us: i64, ) -> Result<Vec<Observation>>

Get observations in time range Target: <5ms for 1-hour window

pub async fn get_orders_for_signal(&self, signal_id: Uuid) -> Result<Vec<Order>>

Get orders for signal Target: <1ms

pub async fn get_recent_signals( &self, symbol: &str, limit: usize, ) -> Result<Vec<Signal>>

Get recent signals Target: <1ms