Struct chaindexing::PostgresRepo

pub struct PostgresRepo { /* private fields */ }

Trait Implementations

impl Clone for PostgresRepo

fn clone(&self) -> PostgresRepo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ExecutesWithRawQuery for PostgresRepo

fn execute_raw_query<'life0, 'life1, 'async_trait>( client: &'life0 Self::RawQueryClient, query: &'life1 str ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn execute_raw_query_in_txn<'a, 'life0, 'life1, 'async_trait>( txn_client: &'life0 Self::RawQueryTxnClient<'a>, query: &'life1 str ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn commit_raw_query_txns<'a, 'async_trait>( client: Self::RawQueryTxnClient<'a> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait,

fn update_next_block_number_to_handle_from_in_txn<'a, 'life0, 'async_trait>( client: &'life0 Self::RawQueryTxnClient<'a>, __arg1: ContractAddressID, block_number: i64 ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn update_every_next_block_number_to_handle_from_in_txn<'a, 'life0, 'async_trait>( client: &'life0 Self::RawQueryTxnClient<'a>, chain_id: i32, block_number: i64 ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn update_reorged_blocks_as_handled_in_txn<'a, 'life0, 'life1, 'async_trait>( client: &'life0 Self::RawQueryTxnClient<'a>, reorged_block_ids: &'life1 Vec<i32> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl HasRawQueryClient for PostgresRepo

type RawQueryClient = Client

type RawQueryTxnClient<'a> = Transaction<'a>

fn get_raw_query_client<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Self::RawQueryClient> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_raw_query_txn_client<'a, 'async_trait>( client: &'a mut Self::RawQueryClient ) -> Pin<Box<dyn Future<Output = Self::RawQueryTxnClient<'a>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait,

impl LoadsDataWithRawQuery for PostgresRepo

fn load_latest_events<'a, 'life0, 'life1, 'async_trait>( client: &'life0 Self::RawQueryClient, addresses: &'life1 Vec<String> ) -> Pin<Box<dyn Future<Output = Vec<PartialEvent>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_data_from_raw_query<'life0, 'life1, 'async_trait, Data>( client: &'life0 Self::RawQueryClient, query: &'life1 str ) -> Pin<Box<dyn Future<Output = Option<Data>> + Send + 'async_trait>>where Data: 'async_trait + Send + DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_data_from_raw_query_with_txn_client<'a, 'life0, 'life1, 'async_trait, Data>( client: &'life0 Self::RawQueryTxnClient<'a>, query: &'life1 str ) -> Pin<Box<dyn Future<Output = Option<Data>> + Send + 'async_trait>>where Data: 'async_trait + Send + DeserializeOwned, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_data_list_from_raw_query<'life0, 'life1, 'async_trait, Data>( client: &'life0 Self::RawQueryClient, query: &'life1 str ) -> Pin<Box<dyn Future<Output = Vec<Data>> + Send + 'async_trait>>where Data: 'async_trait + Send + DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_data_list_from_raw_query_with_txn_client<'a, 'life0, 'life1, 'async_trait, Data>( txn_client: &'life0 Self::RawQueryTxnClient<'a>, query: &'life1 str ) -> Pin<Box<dyn Future<Output = Vec<Data>> + Send + 'async_trait>>where Data: 'async_trait + Send + DeserializeOwned, Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Migratable for PostgresRepo

fn migrate<'life0, 'async_trait>( client: &'life0 Self::RawQueryClient, migrations: Vec<impl 'async_trait + AsRef<str> + Send + Sync> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: Sized + 'async_trait, 'life0: 'async_trait,

impl Repo for PostgresRepo

type Conn<'a> = PooledConnection<'a, AsyncDieselConnectionManager<AsyncPgConnection>>

type Pool = Pool<AsyncDieselConnectionManager<AsyncPgConnection>>

fn new(url: &str) -> Self

fn get_pool<'life0, 'async_trait>( &'life0 self, max_size: u32 ) -> Pin<Box<dyn Future<Output = Pool> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_conn<'a, 'async_trait>( pool: &'a Pool ) -> Pin<Box<dyn Future<Output = Conn<'a>> + Send + 'async_trait>>where 'a: 'async_trait,

fn run_in_transaction<'a, 'life0, 'async_trait, F>( conn: &'life0 mut Conn<'a>, repo_ops: F ) -> Pin<Box<dyn Future<Output = Result<(), RepoError>> + Send + 'async_trait>>where F: for<'b> FnOnce(&'b mut Conn<'a>) -> BoxFuture<'b, Result<(), RepoError>> + Send + Sync + 'a + 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn create_contract_addresses<'a, 'life0, 'life1, 'async_trait>( conn: &'life0 mut Conn<'a>, contract_addresses: &'life1 Vec<UnsavedContractAddress> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_all_contract_addresses<'a, 'life0, 'async_trait>( conn: &'life0 mut Conn<'a> ) -> Pin<Box<dyn Future<Output = Vec<ContractAddress>> + Send + 'async_trait>>where 'a: 'async_trait, 'life0: 'async_trait,

fn create_events<'a, 'life0, 'life1, 'async_trait>( conn: &'life0 mut Conn<'a>, events: &'life1 Vec<Event> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_all_events<'a, 'life0, 'async_trait>( conn: &'life0 mut Conn<'a> ) -> Pin<Box<dyn Future<Output = Vec<Event>> + Send + 'async_trait>>where 'a: 'async_trait, 'life0: 'async_trait,

fn get_events<'a, 'life0, 'async_trait>( conn: &'life0 mut Self::Conn<'a>, address: String, from: u64, to: u64 ) -> Pin<Box<dyn Future<Output = Vec<Event>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn delete_events_by_ids<'a, 'life0, 'life1, 'async_trait>( conn: &'life0 mut Self::Conn<'a>, ids: &'life1 Vec<Uuid> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_next_block_number_to_ingest_from<'a, 'life0, 'life1, 'async_trait>( conn: &'life0 mut Self::Conn<'a>, contract_address: &'life1 ContractAddress, block_number: i64 ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_next_block_number_to_handle_from<'a, 'life0, 'async_trait>( conn: &'life0 mut Conn<'a>, __arg1: ContractAddressID, block_number: i64 ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where 'a: 'async_trait, 'life0: 'async_trait,

fn create_reorged_block<'a, 'life0, 'life1, 'async_trait>( conn: &'life0 mut Self::Conn<'a>, reorged_block: &'life1 UnsavedReorgedBlock ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_unhandled_reorged_blocks<'a, 'life0, 'async_trait>( conn: &'life0 mut Self::Conn<'a> ) -> Pin<Box<dyn Future<Output = Vec<ReorgedBlock>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn create_reset_count<'a, 'life0, 'async_trait>( conn: &'life0 mut Self::Conn<'a> ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

fn get_reset_counts<'a, 'life0, 'async_trait>( conn: &'life0 mut Self::Conn<'a> ) -> Pin<Box<dyn Future<Output = Vec<ResetCount>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait,

impl RepoMigrations for PostgresRepo

fn create_contract_addresses_migration() -> &'static [&'static str]

fn drop_contract_addresses_migration() -> &'static [&'static str]

fn create_events_migration() -> &'static [&'static str]

fn drop_events_migration() -> &'static [&'static str]

fn create_reorged_blocks_migration() -> &'static [&'static str]

fn drop_reorged_blocks_migration() -> &'static [&'static str]

fn create_reset_counts_migration() -> &'static [&'static str]

fn get_internal_migrations() -> Vec<&'static str>

fn get_reset_internal_migrations() -> Vec<&'static str>

impl Streamable for PostgresRepo

type StreamConn<'a> = PooledConnection<'a, AsyncDieselConnectionManager<AsyncPgConnection>>

fn get_contract_addresses_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>> ) -> Box<dyn Stream<Item = Vec<ContractAddress>> + Send + Unpin + 'a>

fn get_events_stream<'a>( conn: Arc<Mutex<Self::StreamConn<'a>>>, from: i64 ) -> Box<dyn Stream<Item = Vec<Event>> + Send + Unpin + 'a>