pub struct BlockchainCache { /* private fields */ }
Expand description
Provides caching functionality for various blockchain domain objects.
Implementations§
Source§impl BlockchainCache
impl BlockchainCache
Sourcepub fn new(chain: SharedChain) -> Self
pub fn new(chain: SharedChain) -> Self
Creates a new in-memory blockchain cache for the specified chain.
Sourcepub fn last_cached_block_number(&self) -> Option<u64>
pub fn last_cached_block_number(&self) -> Option<u64>
Returns the highest block number currently cached, if any.
Sourcepub fn get_block_timestamp(&self, block_number: u64) -> Option<&UnixNanos>
pub fn get_block_timestamp(&self, block_number: u64) -> Option<&UnixNanos>
Returns the timestamp for the specified block number if it exists in the cache.
Sourcepub async fn initialize_database(
&mut self,
pg_connect_options: PgConnectOptions,
)
pub async fn initialize_database( &mut self, pg_connect_options: PgConnectOptions, )
Initializes the database connection for persistent storage.
Sourcepub async fn connect(&mut self, from_block: u64) -> Result<()>
pub async fn connect(&mut self, from_block: u64) -> Result<()>
Connects to the database and loads initial data.
Sourcepub async fn add_block(&mut self, block: Block) -> Result<()>
pub async fn add_block(&mut self, block: Block) -> Result<()>
Adds a block to the cache and persists it to the database if available.
Sourcepub async fn add_dex(&mut self, dex_id: String, dex: DexExtended) -> Result<()>
pub async fn add_dex(&mut self, dex_id: String, dex: DexExtended) -> Result<()>
Adds a DEX to the cache with the specified identifier.
Sourcepub async fn add_pool(&mut self, pool: Pool) -> Result<()>
pub async fn add_pool(&mut self, pool: Pool) -> Result<()>
Adds a liquidity pool/pair to the cache.
Sourcepub async fn add_pool_swap(&self, swap: &PoolSwap) -> Result<()>
pub async fn add_pool_swap(&self, swap: &PoolSwap) -> Result<()>
Adds a [PoolSwap
] to the cache database if available.
Sourcepub async fn add_liquidity_update(
&self,
liquidity_update: &PoolLiquidityUpdate,
) -> Result<()>
pub async fn add_liquidity_update( &self, liquidity_update: &PoolLiquidityUpdate, ) -> Result<()>
Adds a [PoolLiquidityUpdate
] to the cache database if available.
Sourcepub fn get_dex(&self, name: &str) -> Option<&DexExtended>
pub fn get_dex(&self, name: &str) -> Option<&DexExtended>
Returns a reference to the DexExtended
associated with the given name.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for BlockchainCache
impl !RefUnwindSafe for BlockchainCache
impl Send for BlockchainCache
impl Sync for BlockchainCache
impl Unpin for BlockchainCache
impl !UnwindSafe for BlockchainCache
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more