Struct tx_indexer::database::diesel::sync_progress::SyncProgressTable

pub struct SyncProgressTable {
    pub block_slot: i64,
    pub block_hash: Vec<u8>,
    pub processed: bool,
}

Fields

block_slot: i64

block_hash: Vec<u8>

processed: bool

Implementations

impl SyncProgressTable

pub fn new( block_slot: u64, block_hash: String ) -> Result<SyncProgressTable, Error>

pub fn get(conn: &mut PgConnection) -> Result<Option<Self>, Error>

Obtain the sync status of the DB

pub fn store(&self, conn: &mut PgConnection) -> Result<(), Error>

Save a new entity to the database.

pub fn get_or( conn: &mut PgConnection, since_slot: Option<u64>, since_block: Option<String> ) -> Result<Option<(u64, String)>, Error>

Trait Implementations

impl Clone for SyncProgressTable

fn clone(&self) -> SyncProgressTable

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SyncProgressTable

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

Formats the value using the given formatter.

impl<'insert> Insertable<table> for &'insert SyncProgressTable

type Values = <(Option<Grouped<Eq<block_slot, <&'insert i64 as AsExpression<<block_slot as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<block_hash, <&'insert Vec<u8> as AsExpression<<block_hash as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<processed, <&'insert bool as AsExpression<<processed as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self ) -> <(Option<Eq<block_slot, &'insert i64>>, Option<Eq<block_hash, &'insert Vec<u8>>>, Option<Eq<processed, &'insert bool>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl Insertable<table> for SyncProgressTable

type Values = <(Option<Grouped<Eq<block_slot, <i64 as AsExpression<<block_slot as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<block_hash, <Vec<u8> as AsExpression<<block_hash as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<processed, <bool as AsExpression<<processed as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values( self ) -> <(Option<Eq<block_slot, i64>>, Option<Eq<block_hash, Vec<u8>>>, Option<Eq<processed, bool>>) as Insertable<table>>::Values

Construct Self::Values

fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>

where T: Table, Self: Sized,

Insert self into a given table.

impl PartialEq for SyncProgressTable

fn eq(&self, other: &SyncProgressTable) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__DB: Backend, __ST0, __ST1, __ST2> Queryable<(__ST0, __ST1, __ST2), __DB> for SyncProgressTable

where (i64, Vec<u8>, bool): FromStaticSqlRow<(__ST0, __ST1, __ST2), __DB>,

type Row = (i64, Vec<u8>, bool)

The Rust type you’d like to map from.

fn build(row: Self::Row) -> Result<Self>

Construct an instance of this type

impl<__DB: Backend> Selectable<__DB> for SyncProgressTable

type SelectExpression = (block_slot, block_hash, processed)

The expression you’d like to select.

fn construct_selection() -> Self::SelectExpression

Construct an instance of the expression

impl Eq for SyncProgressTable

impl StructuralPartialEq for SyncProgressTable

impl UndecoratedInsertRecord<table> for SyncProgressTable