Struct RecorderDatabase 

pub struct RecorderDatabase { /* private fields */ }

SQLite database for recorder

Implementations

impl RecorderDatabase

pub async fn new<P: AsRef<Path>>(path: P) -> Result<Self>

Create a new database connection

pub async fn new_in_memory() -> Result<Self>

Create an in-memory database (for testing)

pub async fn insert_request(&self, request: &RecordedRequest) -> Result<()>

Insert a new request

pub async fn insert_response(&self, response: &RecordedResponse) -> Result<()>

Insert a response

pub async fn get_request(&self, id: &str) -> Result<Option<RecordedRequest>>

Get a request by ID

pub async fn get_response( &self, request_id: &str, ) -> Result<Option<RecordedResponse>>

Get a response by request ID

pub async fn get_exchange(&self, id: &str) -> Result<Option<RecordedExchange>>

Get an exchange (request + response) by request ID

pub async fn update_response( &self, request_id: &str, status_code: i32, headers: &str, body: &str, size_bytes: i64, ) -> Result<()>

Update an existing response

pub async fn list_recent(&self, limit: i32) -> Result<Vec<RecordedRequest>>

List recent requests

pub async fn delete_older_than(&self, days: i64) -> Result<u64>

Delete old requests

pub async fn get_stats(&self) -> Result<DatabaseStats>

Get database statistics

pub async fn get_statistics(&self) -> Result<DetailedStats>

Get detailed statistics for API

pub async fn clear_all(&self) -> Result<()>

Clear all recordings

pub async fn close(self)

Close the database connection

pub async fn insert_sync_snapshot(&self, snapshot: &SyncSnapshot) -> Result<()>

Insert a sync snapshot

pub async fn get_snapshots_for_endpoint( &self, endpoint: &str, method: Option<&str>, limit: Option<i32>, ) -> Result<Vec<SyncSnapshot>>

Get snapshots for an endpoint

pub async fn get_snapshots_by_cycle( &self, sync_cycle_id: &str, ) -> Result<Vec<SyncSnapshot>>

Get snapshots by sync cycle ID

pub async fn delete_old_snapshots(&self, keep_per_endpoint: i32) -> Result<u64>

Delete old snapshots (retention policy)

pub async fn insert_behavioral_sequence( &self, sequence: &BehavioralSequence, ) -> Result<()>

Insert a behavioral sequence

pub async fn get_behavioral_sequences(&self) -> Result<Vec<BehavioralSequence>>

Get all behavioral sequences

pub async fn insert_endpoint_probability_model( &self, model: &EndpointProbabilityModel, ) -> Result<()>

Insert or update endpoint probability model

pub async fn get_endpoint_probability_model( &self, endpoint: &str, method: &str, ) -> Result<Option<EndpointProbabilityModel>>

Get endpoint probability model

pub async fn get_all_endpoint_probability_models( &self, ) -> Result<Vec<EndpointProbabilityModel>>

Get all endpoint probability models

pub async fn get_requests_by_trace( &self, min_requests_per_trace: Option<i32>, ) -> Result<Vec<(String, Vec<RecordedRequest>)>>

Get requests grouped by trace_id for sequence learning

pub async fn get_exchanges_for_endpoint( &self, endpoint: &str, method: &str, limit: Option<i32>, ) -> Result<Vec<(RecordedRequest, Option<RecordedResponse>)>>

Get requests and responses for a specific endpoint and method

Returns a list of (request, response) pairs for building probability models.

pub async fn create_flow( &self, flow_id: &str, name: Option<&str>, description: Option<&str>, tags: &[String], ) -> Result<()>

Create a new flow

pub async fn add_flow_step( &self, flow_id: &str, request_id: &str, step_index: usize, step_label: Option<&str>, timing_ms: Option<u64>, ) -> Result<()>

Add a step to a flow

pub async fn get_flow_step_count(&self, flow_id: &str) -> Result<usize>

Get the number of steps in a flow

pub async fn get_flow_steps(&self, flow_id: &str) -> Result<Vec<FlowStepRow>>

Get flow steps

pub async fn get_flow_metadata( &self, flow_id: &str, ) -> Result<Option<FlowMetadataRow>>

Get flow metadata

pub async fn list_flows( &self, limit: Option<i64>, ) -> Result<Vec<FlowMetadataRow>>

List flows

pub async fn update_flow_metadata( &self, flow_id: &str, name: Option<&str>, description: Option<&str>, tags: Option<&[String]>, ) -> Result<()>

Update flow metadata

pub async fn delete_flow(&self, flow_id: &str) -> Result<()>

Delete a flow

pub async fn store_scenario( &self, scenario: &BehavioralScenario, version: &str, ) -> Result<()>

Store a behavioral scenario

pub async fn get_scenario( &self, scenario_id: &str, ) -> Result<Option<BehavioralScenario>>

Get a scenario by ID

pub async fn get_scenario_by_name_version( &self, name: &str, version: &str, ) -> Result<Option<BehavioralScenario>>

Get a scenario by name and version

pub async fn list_scenarios( &self, limit: Option<i64>, ) -> Result<Vec<ScenarioMetadataRow>>

List all scenarios

pub async fn delete_scenario(&self, scenario_id: &str) -> Result<()>

Delete a scenario

Trait Implementations

impl Clone for RecorderDatabase

fn clone(&self) -> RecorderDatabase

Returns a duplicate of the value.

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

Performs copy-assignment from source.