MCPcopy Create free account

hub / github.com/cakevm/kabu / functions

Functions1,664 in github.com/cakevm/kabu

↓ 1 callersMethodname
(&self)
crates/strategy/merger/src/samepath_merger_actor.rs:446
↓ 1 callersMethodname
(&self)
crates/strategy/merger/src/diffpath_merger_actor.rs:215
↓ 1 callersMethodname
(&self)
crates/metrics/src/influxdb_actor.rs:91
↓ 1 callersMethodname
(&self)
crates/core/mempool/src/mempool_component.rs:86
↓ 1 callersMethodname
(&self)
crates/core/block-history/src/block_history_actor.rs:275
↓ 1 callersMethodname
(&self)
crates/core/router/src/swap_router_component.rs:105
↓ 1 callersMethodname
(&self)
crates/core/node/src/signer.rs:97
↓ 1 callersMethodname
(&self)
crates/defi/price/src/price_actor.rs:152
↓ 1 callersMethodname
(&self)
crates/defi/health-monitor/src/pool_health_monitor.rs:235
↓ 1 callersMethodname
(&self)
crates/defi/health-monitor/src/metrics_recorder_actor.rs:189
↓ 1 callersMethodname
(&self)
crates/defi/market/src/protocol_pool_loader_component.rs:128
↓ 1 callersMethodname
(&self)
crates/defi/market/src/new_pool_actor.rs:107
↓ 1 callersMethodname
(&self)
crates/defi/market/src/required_pools_actor.rs:152
↓ 1 callersMethodname
(&self)
crates/defi/market/src/history_pool_loader_component.rs:155
↓ 1 callersMethodname
(&self)
crates/defi/market/src/pool_loader_actor.rs:287
↓ 1 callersMethodname
(&self)
crates/broadcast/accounts/src/signers/initialize_actor.rs:87
↓ 1 callersMethodname
(&self)
crates/broadcast/accounts/src/signers/signers_component.rs:274
↓ 1 callersMethodname
(&self)
crates/broadcast/accounts/src/accounts_monitor/account_monitor_component.rs:172
↓ 1 callersMethodname
(&self)
crates/broadcast/broadcaster/src/flashbots.rs:214
↓ 1 callersMethodname
(&self)
crates/rpc/handler/src/web_actor.rs:91
↓ 1 callersMethodname
(&self)
crates/execution/estimator/src/hardhat.rs:145
↓ 1 callersMethodname
(&self)
crates/execution/estimator/src/evm.rs:379
↓ 1 callersMethodname
(&self)
crates/node/json-rpc/src/mempool_processing_component.rs:72
↓ 1 callersMethodnew_block_filter
(self)
crates/node/debug-provider/src/httpcached.rs:148
↓ 1 callersMethodnew_mempool_tx_channel
(&self)
crates/core/blockchain/src/blockchain.rs:92
↓ 1 callersFunctionnew_pool_worker
(client: P, pools_loaders: Arc<PoolLoaders<P, N>>, tasks_tx: broadcast::Sender<LoomTask>)
crates/defi/market/src/new_pool_actor.rs:18
↓ 1 callersFunctionon_upgrade
Actual websocket statemachine (one will be spawned per connection)
crates/rpc/handler/src/handler/ws.rs:27
↓ 1 callersMethodonly_once
(self)
crates/defi/price/src/price_actor.rs:122
↓ 1 callersMethodoptimize_with_in_amount
( &mut self, db: &DB, evm_env: EvmEnv, in_amount: U256, )
crates/types/swap/src/swap_line.rs:433
↓ 1 callersFunctionpending_tx_state_change_worker
( client: P, market: Arc<RwLock<Market>>, mempool: Arc<RwLock<Mempool<LDT>>>, market_state: Ar
crates/strategy/backrun/src/pending_tx_state_change_processor.rs:266
↓ 1 callersFunctionpool_health_monitor_worker
( market: Arc<RwLock<Market>>, mut pool_health_monitor_rx: broadcast::Receiver<MessageHealthEvent>,
crates/defi/health-monitor/src/pool_health_monitor.rs:31
↓ 1 callersFunctionpool_loader_worker
( client: P, pool_loaders: Arc<PoolLoaders<PL, N>>, pools_config: PoolsLoadingConfig, market:
crates/defi/market/src/pool_loader_actor.rs:30
↓ 1 callersMethodpre_estimate_gas
(&self)
crates/types/swap/src/swap.rs:48
↓ 1 callersFunctionpreload_market_state
( client: P, copied_accounts_vec: Vec<Address>, new_accounts_vec: Vec<(Address, u64, U256, Option<
crates/defi/preloader/src/preloader_actor.rs:64
↓ 1 callersFunctionprice_worker
( client: P, market: Arc<RwLock<Market>>, once: bool, )
crates/defi/price/src/price_actor.rs:21
↓ 1 callersMethodprocess_block_range
(&self, from_block: u64, to_block: u64)
crates/defi/market/src/history_pool_loader_component.rs:111
↓ 1 callersFunctionprocess_log_entries
( log_entries: Vec<Log>, pool_loaders: &PoolLoaders<P, N>, tasks_tx: broadcast::Sender<LoomTask>,
crates/defi/market/src/logs_parser.rs:12
↓ 1 callersMethodprofit
(&self)
crates/types/swap/src/swap_line.rs:282
↓ 1 callersFunctionrandomize_tips_pct
(tips_pct: u32)
crates/types/swap/src/tips.rs:60
↓ 1 callersFunctionrayon_run
(state_db: &KabuDBType, pool: PoolWrapper, threadpool: Arc<ThreadPool>)
testing/backtest-runner/benches/benchmark.rs:92
↓ 1 callersMethodread_cached
(&self, method: String, params_hash: B256)
crates/node/debug-provider/src/httpcached.rs:89
↓ 1 callersMethodreplace_account_storage
replace account storage without overriding account info
crates/evm/db/src/kabu_db.rs:217
↓ 1 callersMethodreplace_account_storage
replace account storage without overriding account info
crates/evm/db/src/fast_cache_db.rs:105
↓ 1 callersFunctionrequired_pools_loader_worker
( client: P, pool_loaders: Arc<PoolLoaders<P, N, NP>>, pools: Vec<(PoolId, PoolClass)>, requir
crates/defi/market/src/required_pools_actor.rs:24
↓ 1 callersMethodro_storage_len
(&self)
crates/evm/db/src/kabu_db.rs:108
↓ 1 callersFunctionrouter
( app_state: AppState<DB>, )
crates/rpc/handler/src/router.rs:16
↓ 1 callersFunctionrouter_block
()
crates/rpc/handler/src/router.rs:32
↓ 1 callersFunctionrouter_market
()
crates/rpc/handler/src/router.rs:36
↓ 1 callersMethodrun
(mut self)
crates/core/router/src/swap_router_component.rs:35
↓ 1 callersMethodrun
(self)
crates/defi/market/src/protocol_pool_loader_component.rs:47
↓ 1 callersMethodrun
(self)
crates/defi/market/src/history_pool_loader_component.rs:58
↓ 1 callersMethodrun
(self)
crates/broadcast/accounts/src/signers/signers_component.rs:72
↓ 1 callersMethodrun
(self)
crates/broadcast/accounts/src/accounts_monitor/account_monitor_component.rs:55
↓ 1 callersMethodrun
(self)
crates/node/json-rpc/src/mempool_processing_component.rs:36
↓ 1 callersMethodrw_accounts_len
(&self)
crates/evm/db/src/kabu_db.rs:93
↓ 1 callersMethodrw_contracts_len
(&self)
crates/evm/db/src/kabu_db.rs:90
↓ 1 callersMethodrw_storage_len
(&self)
crates/evm/db/src/kabu_db.rs:105
↓ 1 callersFunctionsame_path_merger_worker
( client: P, market_state: Arc<RwLock<MarketState<DB>>>, mut market_events_rx: broadcast::Receiver
crates/strategy/merger/src/samepath_merger_actor.rs:283
↓ 1 callersFunctionselect_signer_for_swap
Select the most appropriate signer for a given swap
crates/broadcast/accounts/src/signers/signers_component.rs:221
↓ 1 callersMethodsend_canonical_commit
Send a canonical commit notification for a single block The caller needs to provide the block and execution outcome in the appropriate format
crates/node/reth-api/src/provider_wrapper.rs:43
↓ 1 callersMethodset_chain_head
(&self, block_history: &mut BlockHistory<S, NP>, header: NP::BlockHeader)
crates/types/entities/src/block_history/block_history_impl.rs:437
↓ 1 callersMethodset_code
(self, client: P, address: Address)
crates/execution/multicaller/src/deploy.rs:118
↓ 1 callersMethodset_failed
(&mut self, tx_hash: TxHash)
crates/types/blockchain/src/mempool.rs:117
↓ 1 callersFunctionset_monitor_nonce
(account_nonce_balance_state: Option<Arc<RwLock<AccountNonceAndBalanceState>>>, owner: Address, nonce: u64)
crates/defi/preloader/src/preloader_actor.rs:54
↓ 1 callersMethodset_storage
(&self, address: Address, cell: B256, value: B256)
crates/node/debug-provider/src/anvilprovider.rs:61
↓ 1 callersMethodsign
(&'a self, tx_req: TransactionRequest)
crates/types/entities/src/signers.rs:46
↓ 1 callersMethodsign_sync
(&self, tx_req: TransactionRequest)
crates/types/entities/src/signers.rs:62
↓ 1 callersMethodsigner
Replace the signer component
crates/core/node/src/node.rs:245
↓ 1 callersMethodsmart
(&self)
crates/strategy/backrun/src/backrun_config.rs:23
↓ 1 callersMethodsnapshot
(&self)
crates/node/debug-provider/src/anvilprovider.rs:38
↓ 1 callersMethodspawn
(self, executor: TaskExecutor)
crates/node/json-rpc/src/wait_for_node_sync_actor.rs:69
↓ 1 callersMethodstart
(&self)
crates/rpc/handler/src/dto/pagination.rs:20
↓ 1 callersFunctionstart_influxdb_worker
( url: String, database: String, tags: HashMap<String, String>, mut event_receiver: broadcast:
crates/metrics/src/influxdb_actor.rs:11
↓ 1 callersFunctionstart_web_server_worker
( host: String, extra_router: Router<S>, bc: Blockchain, state: BlockchainState<DB, EthPrimiti
crates/rpc/handler/src/web_actor.rs:16
↓ 1 callersFunctionstate_change_arb_searcher_worker
( backrun_config: BackrunConfig, market: Arc<RwLock<Market>>, search_request_rx: broadcast::Receiv
crates/strategy/backrun/src/state_change_arb_searcher.rs:253
↓ 1 callersFunctionstate_health_monitor_worker
( client: P, market_state: Arc<RwLock<MarketState<DB>>>, tx_compose_channel_rx: broadcast::Sender<
crates/defi/health-monitor/src/state_health_monitor.rs:64
↓ 1 callersFunctionstorage_vec_len
(state: &GethStateUpdateVec)
crates/types/market/src/required_state.rs:139
↓ 1 callersMethodstuffing_tx_hash
(&self)
crates/types/events/src/state_update_event.rs:84
↓ 1 callersFunctionstuffing_tx_monitor_worker
( client: P, tx_compose_channel_rx: broadcast::Sender<MessageTxCompose>, market_events_rx: broadca
crates/defi/health-monitor/src/stuffing_tx_monitor.rs:48
↓ 1 callersMethodstuffing_txs
(&self)
crates/types/events/src/state_update_event.rs:80
↓ 1 callersMethodsubscribe_chain_notifications
(&self)
crates/node/reth-api/src/lib.rs:28
↓ 1 callersMethodswap_in_amount_return_offset
(&self, pool: &dyn Pool, token_from_address: Address, token_to_address: Address)
crates/execution/multicaller/src/pool_abi_encoder/abi_encoder.rs:86
↓ 1 callersMethodswap_in_amount_return_script
(&self, pool: &dyn Pool, token_from_address: Address, token_to_address: Address)
crates/execution/multicaller/src/pool_abi_encoder/abi_encoder.rs:97
↓ 1 callersFunctionsync_run
(state_db: &KabuDBType, pool: PoolWrapper)
testing/backtest-runner/benches/benchmark.rs:78
↓ 1 callersMethodtasks_channel
(&self)
crates/core/blockchain/src/blockchain.rs:116
↓ 1 callersFunctiontest_actor_block_history_actor_chain_head_worker
( provider: P, mock_canonical: MockCanonicalProvider<P>, bc: Blockchain<EthPrimitives>
crates/core/block-history/src/block_history_actor_test.rs:111
↓ 1 callersFunctiontest_actor_block_history_actor_reorg_worker
( provider: P, mock_canonical: MockCanonicalProvider<P>, bc: Blockchain<EthPrimitives>
crates/core/block-history/src/block_history_actor_test.rs:286
↓ 1 callersFunctiontest_build_many
(addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:143
↓ 1 callersFunctiontest_build_one
(addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:170
↓ 1 callersFunctiontest_insert_cache_db
(addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:87
↓ 1 callersFunctiontest_insert_kabu_db
(addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:92
↓ 1 callersFunctiontest_read_cache_db
(db: &CacheDB<EmptyDB>, addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:97
↓ 1 callersFunctiontest_read_kabu_db
(db: &KabuDBType, addr: &[Address], accs: &[FastDbAccount])
crates/evm/db/benches/benchmark.rs:107
↓ 1 callersFunctiontest_read_many
(addr: &[Address], accs: &[FastDbAccount], hm: &HashMap<Address, HashMap<U256, U256>>)
crates/evm/db/benches/benchmark.rs:147
↓ 1 callersFunctiontest_read_one
(addr: &[Address], accs: &[FastDbAccount], hm: &HashMap<HashedAddressCell, U256, SimpleBuildHasher>)
crates/evm/db/benches/benchmark.rs:174
↓ 1 callersMethodthreads
(&self)
crates/types/market/src/pool_config.rs:52
↓ 1 callersFunctiontips_and_value_for_swap_type
( swap: &Swap, tips_pct: Option<u32>, gas_cost: Option<U256>, eth_balance: U256, )
crates/types/swap/src/tips.rs:65
↓ 1 callersFunctiontips_pct_advanced
(profit: &U256)
crates/types/swap/src/tips.rs:47
↓ 1 callersMethodto_error
(&self, kind: SwapErrorKind)
crates/types/swap/src/swap_line.rs:135
↓ 1 callersMethodto_float
(&self, value: U256)
crates/types/market/src/token.rs:137
← previousnext →501–600 of 1,664, ranked by callers