kabu_execution_estimator::evm

Function estimator_worker

Source 
async fn estimator_worker<N, DB>(
    client: Option<impl Provider<N> + Clone + 'static>,
    encoder: impl SwapEncoder + Send + Sync + Clone + 'static,
    compose_channel_rx: Broadcaster<MessageSwapCompose<DB>>,
    compose_channel_tx: Broadcaster<MessageSwapCompose<DB>>,
    health_monitor_channel_tx: Option<Broadcaster<MessageHealthEvent>>,
    influxdb_write_channel_tx: Option<Broadcaster<WriteQuery>>,
) -> WorkerResult
where
    N: Network,
    DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + DatabaseKabuExt + Send + Sync + Clone + 'static,