Struct Db 

pub struct Db { /* private fields */ }

The database object, which wraps an inner Arc to the connection pool.

Implementations

impl Db

pub async fn size() -> Result<AdjustedByte>

Get size of SQlite file in megabytes (via async call).

Trait Implementations

impl Clone for Db

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Database for Db

fn setup_connection_pool( settings: &Node, database_url: Option<String>, ) -> Result<Self>

Establish a pooled connection to Sqlite database.

fn conn(&self) -> Result<PooledConnection<ConnectionManager<SqliteConnection>>>

Get a pooled connection for the database.

fn set_url(database_url: Option<String>) -> Option<String>

Set database url.

fn url() -> Result<String>

Get database url.

fn setup(url: &str) -> Result<SqliteConnection>

Test a Sqlite connection to the database and run pending migrations.

fn health_check( conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Health, Error>

Check if the database is up.

fn commit_receipt( workflow_cid: Cid, receipt: Receipt, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Receipt, Error>

Commit a receipt to the database, updating two tables within a transaction.

fn store_receipt( receipt: Receipt, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Option<Receipt>, Error>

Store receipt given a connection to the database pool.

fn store_receipts( receipts: Vec<Receipt>, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<usize, Error>

Store receipts given a connection to the Database pool.

fn find_instruction_pointers( pointers: &Vec<Pointer>, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Vec<Receipt>, Error>

Find receipts given a set of Instruction Pointers, which is indexed.

fn find_instruction_by_cid( cid: Cid, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Receipt, Error>

Find receipt for a given Instruction Cid, which is indexed.

fn find_receipt_by_cid( cid: Cid, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Receipt, Error>

Find a receipt for a given Cid.

fn find_receipt_pointers( pointers: &Vec<Pointer>, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Vec<Receipt>, Error>

Find receipts given a batch of Receipt Pointers.

fn store_workflow( workflow: Stored, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Stored, Error>

Store localized workflow cid and information, e.g. number of tasks.

fn set_workflow_status( workflow_cid: Cid, status: Status, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<(), Error>

Update workflow status given a Cid to the workflow.

fn store_workflow_receipt( workflow_cid: Cid, receipt_cid: Cid, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Option<usize>, Error>

Store workflow Cid and Receipt Cid in the database for inner join.

fn store_workflow_receipts( workflow_cid: Cid, receipts: &[Cid], conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<usize, Error>

Store series of receipts for a workflow Cid in the schema::workflows_receipts table.

fn select_workflow( cid: Cid, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<Stored, Error>

Select workflow given a Cid to the workflow.

fn get_workflow_info( workflow_cid: Cid, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<(Option<String>, Info), Error>

Return workflow information with number of receipts emitted.

fn update_local_name( name: &str, conn: &mut PooledConnection<ConnectionManager<SqliteConnection>>, ) -> Result<(), Error>

Update the local (view) name of a workflow.

impl Debug for Db

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.