Struct BlockWatcherService

pub struct BlockWatcherService<S, H, T, J>
where
    J: JobSchedulerTrait,
{
    pub block_storage: Arc<S>,
    pub block_handler: Arc<H>,
    pub trigger_handler: Arc<T>,
    pub active_watchers: Arc<RwLock<HashMap<String, NetworkBlockWatcher<S, H, T, J>>>>,
    pub block_tracker: Arc<BlockTracker<S>>,
}

Service for managing multiple network watchers

Coordinates block watching across multiple networks, managing individual watchers and their lifecycles.

Type Parameters

• S - Storage implementation for blocks
• H - Handler function for processed blocks
• T - Trigger handler function for processed blocks
• J - Job scheduler implementation (must implement JobSchedulerTrait)

Fields

block_storage: Arc<S>

block_handler: Arc<H>

trigger_handler: Arc<T>

active_watchers: Arc<RwLock<HashMap<String, NetworkBlockWatcher<S, H, T, J>>>>

block_tracker: Arc<BlockTracker<S>>

Implementations

impl<S, H, T, J> BlockWatcherService<S, H, T, J>

where S: BlockStorage + Send + Sync + 'static, H: Fn(BlockType, Network) -> BoxFuture<'static, ProcessedBlock> + Send + Sync + 'static, T: Fn(&ProcessedBlock) -> JoinHandle<()> + Send + Sync + 'static, J: JobSchedulerTrait,

pub async fn new( block_storage: Arc<S>, block_handler: Arc<H>, trigger_handler: Arc<T>, block_tracker: Arc<BlockTracker<S>>, ) -> Result<Self, BlockWatcherError>

Creates a new block watcher service

Arguments

• network_service - Service for network operations
• block_storage - Storage implementation for blocks
• block_handler - Handler function for processed blocks

pub async fn start_network_watcher<C: BlockChainClient + Send + Clone + 'static>( &self, network: &Network, rpc_client: C, ) -> Result<(), BlockWatcherError>

Starts a watcher for a specific network

Arguments

• network - Network configuration to start watching

pub async fn stop_network_watcher( &self, network_slug: &str, ) -> Result<(), BlockWatcherError>

Stops a watcher for a specific network

Arguments

• network_slug - Identifier of the network to stop watching