Struct Db 

pub struct Db { /* private fields */ }

Implementations

impl Db

pub async fn for_write(database_url: Url, config: DbArgs) -> Result<Self>

Construct a new DB connection pool talking to the database at database_url that supports write and reads. Instances of Db can be cloned to share access to the same pool.

pub async fn for_read(database_url: Url, config: DbArgs) -> Result<Self>

Construct a new DB connection pool talking to the database at database_url that defaults to read-only transactions. Instances of Db can be cloned to share access to the same pool.

pub fn register_metrics( self, prefix: Option<&str>, registry: &Registry, ) -> Result<Self>

pub async fn connect(&self) -> Result<Connection<'_>>

Retrieves a connection from the pool. Can fail with a timeout if a connection cannot be established before the DbArgs::connection_timeout has elapsed.

pub fn state(&self) -> State

Statistics about the connection pool

pub fn pool_metrics(&self) -> Option<&PoolMetrics>

pub async fn run_migrations( &self, migrations: Option<&'static EmbeddedMigrations>, ) -> Result<Vec<MigrationVersion<'static>>>

Run migrations on the database. Use Diesel’s embed_migrations! macro to generate the migrations parameter for your indexer.

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConcurrentStore for Db

type ConcurrentConnection<'c> = Connection<'c>

const DELIMITER: &'static str = "@"

Delimiter used to separate pipeline names from task identifiers when reading or writing the committer watermark.

impl SequentialStore for Db

type SequentialConnection<'c> = Connection<'c>

fn transaction<'a, 'life0, 'async_trait, R, F>( &'life0 self, f: F, ) -> Pin<Box<dyn Future<Output = Result<R>> + Send + 'async_trait>>

where R: Send + 'a + 'async_trait, F: Send + 'a + for<'r> FnOnce(&'r mut Self::Connection<'_>) -> ScopedBoxFuture<'a, 'r, Result<R>> + 'async_trait, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

impl Store for Db

type Connection<'c> = Connection<'c>

fn connect<'c, 'async_trait>( &'c self, ) -> Pin<Box<dyn Future<Output = Result<Self::Connection<'c>>> + Send + 'async_trait>>

where Self: 'async_trait, 'c: 'async_trait,