Struct PostgresRecorder 

pub struct PostgresRecorder {
    pub pool: PgPool,
}

Fields

pool: PgPool

Implementations

impl PostgresRecorder

pub async fn new(db_url: &str) -> Result<Self>

pub async fn from_pool(pool: PgPool) -> Result<Self>

Wrap an existing pool, creating the schema on first use. The server constructs the recorder from its own pool (so it shares connection settings), so schema creation must live here rather than only in [new] — otherwise a fresh Postgres has no tables.

Trait Implementations

impl TraceStore for PostgresRecorder

fn record_span<'life0, 'async_trait>( &'life0 self, span: SpanRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn record_event<'life0, 'async_trait>( &'life0 self, event: EventRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record an intra-span event. Defaults to a no-op so existing stores keep compiling; stores that support events override this.