Struct brontes_database::clickhouse::db_client::Clickhouse

pub struct Clickhouse {
    pub tip: bool,
    pub run_id: u64,
    pub client: ClickhouseClient<BrontesClickhouseTables>,
    pub cex_download_config: CexDownloadConfig,
    pub buffered_insert_tx: Option<UnboundedSender<Vec<BrontesClickhouseData>>>,
}

Fields

tip: bool

run_id: u64

client: ClickhouseClient<BrontesClickhouseTables>

cex_download_config: CexDownloadConfig

buffered_insert_tx: Option<UnboundedSender<Vec<BrontesClickhouseData>>>

Implementations

impl Clickhouse

pub async fn new( config: ClickhouseConfig, cex_download_config: CexDownloadConfig, buffered_insert_tx: Option<UnboundedSender<Vec<BrontesClickhouseData>>>, tip: bool, run_id: Option<u64>, ) -> Self

pub async fn new_default(run_id: Option<u64>) -> Self

pub fn inner(&self) -> &ClickhouseClient<BrontesClickhouseTables>

pub async fn get_and_inc_run_id(&self) -> Result<u64>

pub async fn max_traced_block(&self) -> Result<u64>

pub async fn write_searcher_eoa_info( &self, _searcher_eoa: Address, _searcher_info: SearcherInfo, ) -> Result<()>

pub async fn write_searcher_contract_info( &self, _searcher_contract: Address, _searcher_info: SearcherInfo, ) -> Result<()>

pub async fn write_builder_info( &self, _builder_eoa: Address, _builder_info: BuilderInfo, ) -> Result<()>

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

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

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

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

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

pub async fn block_analysis(&self, block_analysis: BlockAnalysis) -> Result<()>

pub async fn save_traces( &self, _block: u64, _traces: Vec<TxTrace>, ) -> Result<()>

pub async fn get_private_flow( &self, tx_hashes_in_block: Vec<TxHash>, ) -> Result<Vec<TxHash>>

pub async fn get_earliest_p2p_observation( &self, block_number: u64, block_hash: BlockHash, ) -> Result<Option<u64>>

impl Clickhouse

pub async fn fetch_symbol_rank( &self, block_times: &[BlockTimes], range_or_arbitrary: &CexRangeOrArbitrary, ) -> Result<Vec<BestCexPerPair>, DatabaseError>

pub async fn get_block_times_range( &self, range: &CexRangeOrArbitrary, ) -> Result<Vec<BlockTimes>, DatabaseError>

pub async fn get_cex_symbols(&self) -> Result<Vec<CexSymbols>, DatabaseError>

pub async fn get_raw_cex_quotes_range( &self, start_time: u64, end_time: u64, ) -> Result<Vec<RawCexQuotes>, DatabaseError>

Trait Implementations

impl ClickhouseHandle for Clickhouse

async fn get_init_crit_tables(&self) -> Result<ClickhouseCritTableCount>

async fn get_metadata( &self, block_num: u64, block_timestamp: u64, block_hash: BlockHash, tx_hashes_in_block: Vec<TxHash>, quote_asset: Address, ) -> Result<Metadata>

async fn query_many_range<T, D>( &self, start_block: u64, end_block: u64, ) -> Result<Vec<D>>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + DbRow + for<'de> Deserialize<'de> + Send + Debug + 'static,

async fn query_many_arbitrary<T, D>( &self, range: &'static [u64], ) -> Result<Vec<D>>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + DbRow + for<'de> Deserialize<'de> + Send + Debug + 'static,

async fn query_many<T, D>(&self) -> Result<Vec<D>>

where T: CompressedTable, T::Value: From<T::DecompressedValue> + Into<T::DecompressedValue>, D: LibmdbxData<T> + DbRow + for<'de> Deserialize<'de> + Send + Debug + 'static,

fn inner(&self) -> &ClickhouseClient<BrontesClickhouseTables>

async fn get_cex_prices( &self, range_or_arbitrary: CexRangeOrArbitrary, ) -> Result<Vec<CexPriceData>>

async fn get_cex_trades( &self, range_or_arbitrary: CexRangeOrArbitrary, ) -> Result<Vec<CexTradesData>>

impl Clone for Clickhouse

fn clone(&self) -> Clickhouse

Returns a copy of the value.

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

Performs copy-assignment from source.

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: 232 bytes