Struct brontes_database::libmdbx::LibmdbxReadWriter

pub struct LibmdbxReadWriter {
    pub db: Arc<Libmdbx>,
    pub tx: UnboundedSender<StampedWriterMessage>,
    /* private fields */
}

Fields

db: Arc<Libmdbx>

tx: UnboundedSender<StampedWriterMessage>

Implementations

impl LibmdbxReadWriter

pub fn write_partition_range_data<T, D>( &self, start_block: u64, end_block: u64, write_db: &LibmdbxReadWriter, pb: Option<&ProgressBar>, ) -> Result<()>

where T: CompressedTable<Key = u64>, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + From<(T::Key, T::DecompressedValue)>, InitTables: From<Vec<D>>,

pub fn write_dex_price_range( &self, start_block: u64, end_block: u64, write_db: &LibmdbxReadWriter, pb: Option<&ProgressBar>, ) -> Result<()>

pub fn write_critical_data<T, D>( &self, write_db: &LibmdbxReadWriter, mult_pb: Option<MultiProgress>, ) -> Result<()>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + From<(T::Key, T::DecompressedValue)>, InitTables: From<Vec<D>>,

pub fn write_partitioned_range_data<T, D>( &self, data: Vec<(T::Key, T::DecompressedValue)>, ) -> Result<()>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + From<(T::Key, T::DecompressedValue)>, InitTables: From<Vec<D>>,

impl LibmdbxReadWriter

pub fn init_db<P: AsRef<Path>>( path: P, log_level: Option<LogLevel>, ex: &BrontesTaskExecutor, metrics: bool, ) -> Result<Self>

pub fn init_db_tests<P: AsRef<Path>>(path: P) -> Result<Self>

impl LibmdbxReadWriter

pub fn get_crit_table_count(&self) -> Result<ClickhouseCritTableCount>

pub fn convert_into_save_bytes<T: CompressedTable>( data: ReturnKV<T>, ) -> (<T::Key as Encode>::Encoded, <T::Value as Compress>::Compressed)

where T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>,

pub fn inited_range_arbitrary( &self, range: impl Iterator<Item = u64>, flag: u16, ) -> Result<Vec<InitializedStateData>>

pub fn inited_range_items( &self, range: RangeInclusive<u64>, flag: u16, ) -> Result<Vec<InitializedStateData>>

pub fn inited_range(&self, range: RangeInclusive<u64>, flag: u16) -> Result<()>

pub fn fetch_trades(&self, block: u64) -> Result<CexTradeMap>

pub fn fetch_cex_quotes(&self, block_num: u64) -> Result<CexPriceMap>

pub fn fetch_dex_quotes(&self, block_num: u64) -> Result<DexQuotes>

pub fn send_message(&self, message: WriterMessage) -> Result<()>

pub fn get_table_entry_count<T>(&self) -> Result<usize>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>,

pub fn get_highest_block_number(&self) -> Result<u64>

Trait Implementations

impl Clone for LibmdbxReadWriter

fn clone(&self) -> LibmdbxReadWriter

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DBWriter for LibmdbxReadWriter

async fn insert_tree(&self, _tree: BlockTree<Action>) -> Result<()>

only for internal functionality (i.e. clickhouse)

async fn write_block_analysis(&self, _: BlockAnalysis) -> Result<()>

only for internal functionality (i.e. clickhouse)

type Inner = LibmdbxReadWriter

allows for writing results to multiple databases

fn inner(&self) -> &Self::Inner

async fn write_searcher_info( &self, eoa_address: Address, contract_address: Option<Address>, eoa_info: SearcherInfo, contract_info: Option<SearcherInfo>, ) -> Result<()>

async fn write_searcher_eoa_info( &self, searcher_eoa: Address, searcher_info: SearcherInfo, ) -> Result<()>

async fn write_searcher_contract_info( &self, searcher_contract: Address, searcher_info: SearcherInfo, ) -> Result<()>

async fn write_address_meta( &self, address: Address, metadata: AddressMetadata, ) -> Result<()>

async fn save_mev_blocks( &self, block_number: u64, block: MevBlock, mev: Vec<Bundle>, ) -> Result<()>

async fn write_dex_quotes( &self, block_number: u64, quotes: Option<DexQuotes>, ) -> Result<()>

async fn write_token_info( &self, address: Address, decimals: u8, symbol: String, ) -> Result<()>

async fn insert_pool( &self, block: u64, address: Address, tokens: &[Address], curve_lp_token: Option<Address>, classifier_name: Protocol, ) -> Result<()>

async fn save_traces(&self, block: u64, traces: Vec<TxTrace>) -> Result<()>

async fn write_builder_info( &self, builder_address: Address, builder_info: BuilderInfo, ) -> Result<()>

impl LibmdbxInit for LibmdbxReadWriter

async fn initialize_table<T: TracingProvider, CH: ClickhouseHandle>( &'static self, clickhouse: &'static CH, tracer: Arc<T>, tables: Tables, clear_tables: bool, block_range: Option<(u64, u64)>, progress_bar: Arc<Vec<(Tables, ProgressBar)>>, metrics: bool, ) -> Result<()>

Initializes a table for a given range of blocks

async fn initialize_table_arbitrary<T: TracingProvider, CH: ClickhouseHandle>( &'static self, clickhouse: &'static CH, tracer: Arc<T>, tables: Tables, block_range: Vec<u64>, progress_bar: Arc<Vec<(Tables, ProgressBar)>>, metrics: bool, ) -> Result<()>

Initializes a table for a given range of blocks

async fn initialize_full_range_tables<T: TracingProvider, CH: ClickhouseHandle>( &'static self, clickhouse: &'static CH, tracer: Arc<T>, metrics: bool, ) -> Result<()>

Initialize the small tables that aren’t indexed by block number

fn state_to_initialize( &self, start_block: u64, end_block: u64, ) -> Result<StateToInitialize>

fn get_db_range(&self) -> Result<(u64, u64)>

impl LibmdbxReader for LibmdbxReadWriter

fn get_most_recent_block(&self) -> Result<u64>

fn get_dex_quotes(&self, block: u64) -> Result<DexQuotes>

fn get_cex_trades(&self, block: u64) -> Result<CexTradeMap>

fn has_dex_quotes(&self, block_num: u64) -> Result<bool>

fn load_trace(&self, block_num: u64) -> Result<Vec<TxTrace>>

fn get_protocol_details(&self, address: Address) -> Result<ProtocolInfo>

fn get_metadata_no_dex_price( &self, block_num: u64, quote_asset: Address, ) -> Result<Metadata>

fn get_metadata(&self, block_num: u64, quote_asset: Address) -> Result<Metadata>

fn try_fetch_token_info( &self, og_address: Address, ) -> Result<TokenInfoWithAddress>

fn try_fetch_searcher_eoa_infos( &self, searcher_eoa: Vec<Address>, ) -> Result<FastHashMap<Address, SearcherInfo>>

fn try_fetch_searcher_eoa_info( &self, searcher_eoa: Address, ) -> Result<Option<SearcherInfo>>

fn try_fetch_searcher_contract_infos( &self, searcher: Vec<Address>, ) -> Result<FastHashMap<Address, SearcherInfo>>

fn try_fetch_searcher_contract_info( &self, searcher_contract: Address, ) -> Result<Option<SearcherInfo>>

fn fetch_all_searcher_eoa_info(&self) -> Result<Vec<(Address, SearcherInfo)>>

fn fetch_all_searcher_contract_info( &self, ) -> Result<Vec<(Address, SearcherInfo)>>

fn protocols_created_before( &self, block_num: u64, ) -> Result<FastHashMap<(Address, Protocol), Pair>>

fn protocols_created_range( &self, start_block: u64, end_block: u64, ) -> Result<FastHashMap<u64, Vec<(Address, Protocol, Pair)>>>

fn try_fetch_address_metadatas( &self, addresses: Vec<Address>, ) -> Result<FastHashMap<Address, AddressMetadata>>

fn try_fetch_address_metadata( &self, address: Address, ) -> Result<Option<AddressMetadata>>

fn try_fetch_builder_info( &self, builder_coinbase_addr: Address, ) -> Result<Option<BuilderInfo>>

fn fetch_all_builder_info(&self) -> Result<Vec<(Address, BuilderInfo)>>

fn try_fetch_mev_blocks( &self, start_block: Option<u64>, end_block: u64, ) -> Result<Vec<MevBlockWithClassified>>

fn fetch_all_mev_blocks( &self, start_block: Option<u64>, ) -> Result<Vec<MevBlockWithClassified>>

fn fetch_all_address_metadata(&self) -> Result<Vec<(Address, AddressMetadata)>>

fn try_fetch_searcher_info( &self, eoa_address: Address, contract_address: Option<Address>, ) -> Result<(Option<SearcherInfo>, Option<SearcherInfo>), Report>

fn try_fetch_searcher_infos( &self, eoa: Vec<Address>, contract: Vec<Address>, ) -> Result<HashMap<Address, (SearcherInfo, Option<SearcherInfo>), RandomState>, Report>

fn fetch_all_searcher_info( &self, ) -> Result<(Vec<(Address, SearcherInfo)>, Vec<(Address, SearcherInfo)>), Report>

fn try_fetch_token_decimals(&self, address: Address) -> Result<u8, Report>

fn get_protocol(&self, address: Address) -> Result<Protocol, Report>

fn get_protocol_details_sorted( &self, address: Address, ) -> Result<ProtocolInfo, Report>

returns protocol details with the tokens sorted from smallest to biggest. This is needed as for some reason the tokens in the database for a given protocol don’t seems to always be ordered correctly

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 104 bytes