Struct TraceStore 

pub struct TraceStore { /* private fields */ }

Trace store for persisting traces to PostgreSQL.

Implementations

impl TraceStore

pub fn new(pool: PgPool) -> Self

Create a new trace store.

pub async fn store(&self, spans: Vec<Span>) -> Result<()>

Store a batch of spans to the database.

pub async fn get_trace(&self, trace_id: &str) -> Result<Vec<Span>>

Get a trace by ID.

pub async fn query( &self, from: DateTime<Utc>, to: DateTime<Utc>, limit: usize, ) -> Result<Vec<String>>

Query traces by time range.

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

List recent traces with summary info.

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

Find traces with errors.

pub async fn trace_count(&self) -> usize

Get trace count.

pub async fn span_count(&self) -> usize

Get total span count.

pub async fn cleanup(&self, retention: Duration) -> Result<u64>

Run cleanup to remove old traces.