Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cakevm/kabu
/ functions
Functions
1,664 in github.com/cakevm/kabu
⨍
Functions
1,664
◇
Types & classes
333
↓ 1 callers
Method
to_float
(value: U256)
crates/evm/utils/src/nweth.rs:20
↓ 1 callers
Function
tokio_run
(state_db: &KabuDBType, pool: PoolWrapper)
testing/backtest-runner/benches/benchmark.rs:172
↓ 1 callers
Function
tx_evm_env_from_tx
(tx: T)
crates/evm/utils/src/evm_env.rs:70
↓ 1 callers
Method
update_cells
(&self)
crates/evm/db/src/in_memory_db.rs:69
↓ 1 callers
Function
update_nonces_from_block
(account_state: &Arc<RwLock<AccountNonceAndBalanceState>>, block: &RecoveredBlock<Block>)
crates/broadcast/accounts/src/accounts_monitor/account_monitor_component.rs:133
↓ 1 callers
Method
vec
(self)
crates/types/market/src/swap_path_builder.rs:23
↓ 1 callers
Function
wait_for_node_sync_one_shot_worker
Wait for the node to sync. This works only for http/ipc/ws providers.
crates/node/json-rpc/src/wait_for_node_sync_actor.rs:17
↓ 1 callers
Method
wait_for_shutdown
Wait for the node to finish (never returns in normal operation)
crates/core/node/src/builder.rs:185
↓ 1 callers
Method
with_block_history
(self, block_history: Arc<RwLock<BlockHistory<DB, LDT>>>)
crates/strategy/backrun/src/arb_actor.rs:89
↓ 1 callers
Method
with_channel
(self, channel: Option<broadcast::Sender<WriteQuery>>)
crates/metrics/src/influxdb_actor.rs:73
↓ 1 callers
Method
with_compose_channel
(self, compose_channel: broadcast::Sender<MessageSwapCompose<DB>>)
crates/strategy/merger/src/swappath_merger_actor.rs:253
↓ 1 callers
Method
with_config
( mut self, chain_parameters: ChainParameters, market_state: Arc<RwLock<MarketState<DB
crates/core/block-history/src/block_history_actor.rs:229
↓ 1 callers
Method
with_config
(self, config: PoolsLoadingConfig)
crates/defi/pools/src/loaders/mod.rs:89
↓ 1 callers
Method
with_copied_account
(self, address: Address)
crates/defi/preloader/src/preloader_actor.rs:190
↓ 1 callers
Method
with_influxdb_channel
(self, influxdb_tx: broadcast::Sender<WriteQuery>)
crates/strategy/backrun/src/arb_actor.rs:109
↓ 1 callers
Method
with_market_state
(self, market_state: Arc<RwLock<MarketState<DB>>>)
crates/strategy/backrun/src/arb_actor.rs:85
↓ 1 callers
Method
with_mempool_events_channel
(self, mempool_events_tx: broadcast::Sender<MempoolEvents>)
crates/strategy/backrun/src/arb_actor.rs:93
↓ 1 callers
Method
with_monitor
(self, monitor: Arc<RwLock<AccountNonceAndBalanceState>>)
crates/broadcast/accounts/src/signers/initialize_actor.rs:67
↓ 1 callers
Method
with_pool_health_monitor_channel
(self, pool_health_monitor_tx: broadcast::Sender<MessageHealthEvent>)
crates/strategy/backrun/src/arb_actor.rs:105
↓ 1 callers
Method
with_provider
(self, provider: NewP)
crates/defi/pools/src/loaders/mod.rs:85
↓ 1 callers
Method
with_relays
(mut self, relay_configs: Vec<RelayConfig>)
crates/broadcast/broadcaster/src/flashbots.rs:188
↓ 1 callers
Method
write_cached
(&self, method: String, params_hash: B256, data: String)
crates/node/debug-provider/src/httpcached.rs:96
Function
_limit_default
()
crates/rpc/handler/src/dto/pagination.rs:7
Function
_page_default
()
crates/rpc/handler/src/dto/pagination.rs:4
Method
account_db_to_revm
(db: FastDbAccount)
crates/evm/db/src/database_helpers.rs:15
Method
account_info
(&self)
crates/execution/multicaller/src/deploy.rs:36
Method
add
(&mut self, opcode: MulticallerCall)
crates/types/blockchain/src/opcodes.rs:151
Method
add_calls_with_optional_value
(&self, calls: &mut MulticallerCalls, call_list: Vec<(Address, Bytes, Option<U256>)>)
crates/execution/multicaller/src/swapstep_encoder.rs:181
Method
add_db
(&mut self, block_hash: BlockHash, state: S)
crates/types/entities/src/block_history/block_history_impl.rs:83
Method
add_loader
(self, pool_class: PoolClass, loader: L)
crates/types/market/src/pool_loader.rs:64
Method
add_logs
(&mut self, block_hash: BlockHash, logs: Vec<Log>)
crates/types/entities/src/block_history/block_history_impl.rs:203
Method
add_state_diff
(&mut self, block_hash: BlockHash, state_diff: GethStateUpdateVec)
crates/types/entities/src/block_history/block_history_impl.rs:185
Method
add_tx_hash
(&mut self, tx_hash: TxHash)
crates/types/blockchain/src/accountnoncetx.rs:14
Method
add_tx_logs
(&mut self, tx_hash: TxHash, logs: Vec<Log>)
crates/types/blockchain/src/mempool.rs:43
Method
add_tx_state_change
(&mut self, tx_hash: TxHash, state_update: GethStateUpdate)
crates/types/blockchain/src/mempool.rs:49
Method
address
(&self)
crates/types/market/src/pool.rs:330
Method
address
(&self)
crates/execution/multicaller/src/swap_encoder.rs:16
Method
address_or
(&self, default_address: Address)
crates/types/market/src/pool.rs:324
Method
all_disabled
()
crates/node/node-config/src/lib.rs:10
Method
all_enabled
()
crates/node/node-config/src/lib.rs:14
Method
allowance
( db: &DB, evm_env: &EvmEnv, erc20_token: Address, owner: Address, spe
crates/defi/pools/src/state_readers/erc20.rs:29
Function
append_all_matching_block_logs
Appends all matching logs of a block's receipts. If the log matches, look up the corresponding transaction hash.
crates/evm/utils/src/reth_types.rs:17
Function
append_all_matching_block_logs_sealed
Appends all matching logs of a block's receipts. If the log matches, look up the corresponding transaction hash.
crates/evm/utils/src/reth_types.rs:57
Method
apply_geth_state_update
(db: &mut DB, update: BTreeMap<Address, AccountState>)
crates/evm/db/src/database_helpers.rs:54
Method
apply_geth_state_update_vec
(db: &mut DB, update_vec: Vec<BTreeMap<Address, AccountState>>)
crates/evm/db/src/database_helpers.rs:60
Method
apply_geth_update_vec
(&mut self, update: GethStateUpdateVec)
crates/types/market/src/market_state.rs:68
Method
apply_geth_update_vec
(&mut self, update: Vec<BTreeMap<Address, GethAccountState>>)
crates/evm/db/src/in_memory_db.rs:122
Method
apply_state_update_on_parent_db
( &self, block_history: &mut BlockHistory<S, NP>, market_state_config: &MarketStateCon
crates/types/entities/src/block_history/block_history_impl.rs:416
Method
arb_profit
(swap_step_0: &SwapStep, swap_step_1: &SwapStep)
crates/types/swap/src/swap_step.rs:477
Method
arb_profit_eth
(swap_step_0: &SwapStep, swap_step_1: &SwapStep)
crates/types/swap/src/swap_step.rs:483
Method
arb_result
(swap_step_0: &SwapStep, swap_step_1: &SwapStep)
crates/types/swap/src/swap_step.rs:471
Function
arb_swap_path_merger_worker
( provider: R, multicaller_address: Address, market_events_rx: broadcast::Sender<MarketEvents>,
crates/strategy/merger/src/swappath_merger_actor.rs:64
Function
arb_swap_steps_optimizer_task
( compose_channel_tx: broadcast::Sender<MessageSwapCompose<DB>>, _state_db: DB, block_number: u64,
crates/strategy/merger/src/swappath_merger_actor.rs:18
Method
arc_vec
(self)
crates/types/market/src/swap_path_builder.rs:28
Function
array_of_strings
()
crates/rpc/handler/src/dto/pool.rs:39
Method
as_any
(&self)
crates/types/market/src/mock_pool.rs:25
Method
as_any
(&self)
crates/types/market/src/swap_path.rs:294
Method
as_any
(&self)
crates/defi/pools/src/curvepool.rs:217
Method
as_any
(&self)
crates/defi/pools/src/uniswapv3pool.rs:219
Method
as_any
(&self)
crates/defi/pools/src/maverickpool.rs:144
Method
as_any
(&self)
crates/defi/pools/src/pancakev3pool.rs:179
Method
as_any
(&self)
crates/defi/pools/src/uniswapv2pool.rs:198
Function
async_test
()
crates/types/market/src/swap_path.rs:397
Method
balance
(client: P, address: Address, coin_id: u32)
crates/defi/pools/src/protocols/curve.rs:146
Method
balance128
(client: P, address: Address, coin_id: u32)
crates/defi/pools/src/protocols/curve.rs:128
Method
balance_of
( db: &DB, evm_env: &EvmEnv, erc20_token: Address, account: Address, )
crates/defi/pools/src/state_readers/erc20.rs:15
Method
basic
(&mut self, address: Address)
crates/evm/db/src/kabu_db.rs:561
Method
basic
(&mut self, address: Address)
crates/evm/db/src/fast_cache_db.rs:149
Method
basic
(&mut self, address: Address)
crates/evm/db/src/alloydb.rs:158
Function
bench_swap_calculator
(c: &mut Criterion)
crates/strategy/backrun/benches/swap_calculation_bench.rs:16
Function
benchmark
(c: &mut Criterion)
testing/backtest-runner/benches/benchmark.rs:287
Function
benchmark_test_group_hasher
(c: &mut Criterion)
crates/types/entities/benches/benchmark.rs:59
Function
benchmark_test_group_hasher
(c: &mut Criterion)
crates/evm/db/benches/benchmark.rs:284
Function
benchmark_test_group_hashmap
(c: &mut Criterion)
crates/evm/db/benches/benchmark.rs:258
Function
benchmark_test_group_trait
(c: &mut Criterion)
crates/evm/db/benches/benchmark.rs:296
Method
block_hash
(&mut self, number: BlockNumber)
crates/evm/db/src/kabu_db.rs:624
Method
block_hash
(&mut self, number: BlockNumber)
crates/evm/db/src/fast_cache_db.rs:209
Method
block_hash
(&mut self, number: u64)
crates/evm/db/src/alloydb.rs:173
Method
block_hash_ref
(&self, number: u64)
crates/evm/db/src/alloydb.rs:140
Method
broadcast
(data: TxComposeData<N>)
crates/types/events/src/tx_compose.rs:89
Function
broadcast_task
(broadcast_request: TxComposeData, relays: Arc<Vec<FlashbotsRelay>>)
crates/broadcast/broadcaster/src/flashbots.rs:58
Method
broadcaster
Set the broadcaster builder
crates/core/components/src/builder.rs:410
Method
broadcaster
Replace the broadcaster component
crates/core/node/src/node.rs:165
Method
build
Build the node with the configured components
crates/core/components/src/kabu_builder.rs:38
Method
build
Build all components without spawning
crates/core/components/src/builder.rs:200
Method
build
( self, signers: Arc<RwLock<TxSigners<LDT>>>, account_nonce_balance: Arc<RwLock<Accoun
crates/core/router/src/swap_router_component.rs:120
Method
build
(self, _ctx: &Ctx)
crates/core/node/src/traits.rs:32
Method
build
(self, ctx: &KabuContext<R, P, DB, Evm>)
crates/core/node/src/defaults.rs:56
Method
build
(self, client: P, pool_loaders: Arc<PoolLoaders<PL, N>>)
crates/defi/market/src/protocol_pool_loader_component.rs:143
Method
build
(self, client: P, pool_loaders: Arc<PoolLoaders<PL, N, EthPrimitives>>)
crates/defi/market/src/history_pool_loader_component.rs:191
Method
build
( self, client: P, signers: Arc<RwLock<TxSigners<LDT>>>, account_state: Arc<Rw
crates/broadcast/accounts/src/signers/signers_component.rs:296
Method
build
( self, reth_provider: R, account_state: Arc<RwLock<AccountNonceAndBalanceState>>,
crates/broadcast/accounts/src/accounts_monitor/account_monitor_component.rs:185
Method
build
(self, client: P)
crates/node/json-rpc/src/mempool_processing_component.rs:87
Method
build_and_spawn
Build all components and spawn them
crates/core/components/src/builder.rs:183
Method
build_call_stack
( amount: SwapAmountType, call: MulticallerCall, offset: u32, len: usize,
crates/execution/multicaller/src/opcodes_helpers.rs:20
Method
build_log_stack
(size: usize)
crates/execution/multicaller/src/opcodes_helpers.rs:10
Method
build_multiple_stack
( amount: SwapAmountType, calls: Vec<(MulticallerCall, u32, usize)>, balance_of_token:
crates/execution/multicaller/src/opcodes_helpers.rs:57
Function
build_swap_path_four_hopes_basic_in
( market: &Market, pool: &PoolWrapper, token_from_address: &Address, token_to_address: &Addres
crates/types/market/src/swap_path_builder.rs:122
Function
build_swap_path_four_hopes_basic_out
( market: &Market, pool: &PoolWrapper, token_from_address: &Address, token_to_address: &Addres
crates/types/market/src/swap_path_builder.rs:288
Function
calc_coinbase_diff
(client: P, tx_hash: TxHash, coinbase: Address)
crates/defi/health-monitor/src/stuffing_tx_monitor.rs:36
← previous
next →
601–700 of 1,664, ranked by callers