Functions — github.com/AV1080p/Solana-Arbitrage-Bot

CodeHub MCPcopy Create free account

hub / github.com/AV1080p/Solana-Arbitrage-Bot / functions

Functions134 in github.com/AV1080p/Solana-Arbitrage-Bot

⨍ Functions 134◇ Types & classes 35

↓ 113 callersMethodlog

Method to log a message with a prefix

src/shared/logger.rs:22

↓ 22 callersMethodget

src/shared/config.rs:125

↓ 15 callersFunctionimport_env_var

src/shared/config.rs:235

↓ 8 callersFunctionlog_raw_transaction

Logs raw transaction data to a file without parsing

src/record/transaction_logger.rs:37

↓ 7 callersFunctionget_tip_account

src/infrastructure/services/jito.rs:15

↓ 6 callersFunctionget_associated_token_address

( client: Arc<anchor_client::solana_client::nonblocking::rpc_client::RpcClient>, keypair: Arc<Keypair>

src/domain/token.rs:145

↓ 5 callersFunctionget_unit_limit

src/domain/tx.rs:360

↓ 5 callersFunctionget_unit_price

prioritization fee = UNIT_PRICE * UNIT_LIMIT

src/domain/tx.rs:356

↓ 5 callersMethodsend_transaction

( &self, transaction: &Transaction, )

src/infrastructure/services/jito.rs:210

↓ 4 callersFunctionget_tip_value

src/infrastructure/services/jito.rs:41

↓ 3 callersMethodbuild_swap_ixn_by_mint

( &self, mint_str: &str, pool: Option<PumpSwapPool>, swap_config: SwapConfig,

src/infrastructure/dex/pump_swap.rs:72

↓ 3 callersFunctioncheck_connection_health

Add this function to check connection health based on message reception

src/application/monitor.rs:190

↓ 3 callersFunctionextract_target_address_from_transaction

Helper function to extract target address from a transaction

src/application/monitor.rs:718

↓ 3 callersMethodfind_dex_by_program_id

Find a DEX by program ID

src/infrastructure/dex/dex_registry.rs:178

↓ 3 callersFunctionget_account_info

( client: Arc<anchor_client::solana_client::nonblocking::rpc_client::RpcClient>, address: Pubkey,

src/domain/token.rs:164

↓ 3 callersMethodget_all_dexes

Get all registered DEXes

src/infrastructure/dex/dex_registry.rs:158

↓ 3 callersFunctionis_meteora_dlmm_transaction

Check if a transaction is from Meteora DLMM

src/record/transaction_logger.rs:202

↓ 3 callersFunctionis_meteora_pools_transaction

Check if a transaction is from Meteora Pools

src/record/transaction_logger.rs:192

↓ 3 callersFunctionis_pumpfun_transaction

Check if a transaction is from PumpFun

src/record/transaction_logger.rs:132

↓ 3 callersFunctionis_pumpswap_transaction

Check if a transaction is from PumpSwap

src/record/transaction_logger.rs:142

↓ 3 callersFunctionis_raydium_cpmm_transaction

Check if a transaction is from Raydium CPMM

src/record/transaction_logger.rs:162

↓ 3 callersFunctionis_raydium_transaction

Check if a transaction is from Raydium

src/record/transaction_logger.rs:152

↓ 3 callersFunctionis_stable_swap_transaction

Check if a transaction is from Stable Swap

src/record/transaction_logger.rs:182

↓ 3 callersFunctionis_whirlpool_transaction

Check if a transaction is from Whirlpool

src/record/transaction_logger.rs:172

↓ 3 callersFunctionnew_signed_and_send_zeroslot

( recent_blockhash: anchor_client::solana_sdk::hash::Hash, keypair: &Keypair, mut instructions: Ve

src/domain/tx.rs:297

↓ 3 callersFunctionprocess_stream_message

Process stream messages including ping-pong for keepalive

src/application/monitor.rs:769

↓ 3 callersFunctionsend_heartbeat_ping

Heartbeat function to periodically send pings

src/application/monitor.rs:788

↓ 2 callersFunctionensure_record_dirs

Function to ensure record directories exist

src/application/monitor.rs:812

↓ 2 callersFunctionextract_pool_info_from_transaction

Helper function to extract pool information from a transaction

src/application/monitor.rs:598

↓ 2 callersMethodget_cache

Get a clone of the current cache

src/application/pool_discovery.rs:114

↓ 2 callersFunctionget_pool_info

Get the PumpSwap pool information for a specific token mint

src/infrastructure/dex/pump_swap.rs:346

↓ 2 callersMethodsave

Save pool cache to file

src/application/pool_discovery.rs:56

↓ 2 callersFunctionsave_transaction_record

Save transaction data to a file

src/application/monitor.rs:830

↓ 1 callersMethodadd_pool

Add a pool to the cache

src/application/pool_discovery.rs:64

↓ 1 callersFunctionarbitrage_monitor

Function to monitor for arbitrage opportunities

src/application/monitor.rs:2197

↓ 1 callersFunctioncalculate_buy_base_amount

Calculate the amount of base tokens received for a given quote amount in buy operation

src/infrastructure/dex/pump_swap.rs:413

↓ 1 callersFunctioncalculate_sell_quote_amount

Calculate the amount of quote tokens received for a given base amount in sell operation

src/infrastructure/dex/pump_swap.rs:438

↓ 1 callersFunctioncreate_buy_accounts

Create accounts for buy operation

src/infrastructure/dex/pump_swap.rs:481

↓ 1 callersFunctioncreate_coingecko_proxy

src/shared/config.rs:264

↓ 1 callersFunctioncreate_nonblocking_rpc_client

src/shared/config.rs:253

↓ 1 callersFunctioncreate_rpc_client

src/shared/config.rs:245

↓ 1 callersFunctioncreate_sell_accounts

Create accounts for sell operation

src/infrastructure/dex/pump_swap.rs:521

↓ 1 callersFunctioncreate_swap_instruction

Create a swap instruction with the given parameters

src/infrastructure/dex/pump_swap.rs:561

↓ 1 callersFunctiondetermine_protocol

Determine protocol from transaction logs

src/application/monitor.rs:851

↓ 1 callersFunctiondiscover_pools_for_token

Discover pools for a token across all supported DEXes

src/application/pool_discovery.rs:148

↓ 1 callersFunctionensure_record_dirs

Program IDs for the protocols we're interested in

src/record/transaction_logger.rs:8

↓ 1 callersFunctionextract_transaction_type

Extract transaction type from logs

src/application/monitor.rs:885

↓ 1 callersFunctionget_expire_condition

Get expiration time for transaction

src/infrastructure/dex/pump_swap.rs:582

↓ 1 callersFunctionget_mint_info

( client: Arc<anchor_client::solana_client::nonblocking::rpc_client::RpcClient>, _keypair: Arc<Keypair

src/domain/token.rs:196

↓ 1 callersFunctionget_nozomi_tip

Functions to get tip values at runtime

src/domain/tx.rs:51

↓ 1 callersFunctionget_priority_fee

src/infrastructure/services/jito.rs:59

↓ 1 callersFunctionget_program_accounts_with_filters

Helper function to get program accounts with filters

src/application/pool_discovery.rs:207

↓ 1 callersMethodget_token_price

(&self, mint_str: &str)

src/infrastructure/dex/pump_swap.rs:332

↓ 1 callersFunctionhandle_ping_message

Send a ping response when we receive a ping

src/application/monitor.rs:745

↓ 1 callersFunctionimport_wallet

src/shared/config.rs:276

↓ 1 callersFunctioninitialize_pool_cache

Function to initialize pool cache for a list of token mints

src/application/pool_discovery.rs:228

↓ 1 callersMethodis_debug

src/shared/logger.rs:75

↓ 1 callersFunctionmax_amount_with_slippage

Calculate the maximum amount with slippage tolerance

src/infrastructure/dex/pump_swap.rs:472

↓ 1 callersFunctionmin_amount_with_slippage

Calculate the minimum amount with slippage tolerance

src/infrastructure/dex/pump_swap.rs:463

↓ 1 callersFunctionnew_progress_bar

src/infrastructure/services/jito.rs:152

↓ 1 callersFunctionnew_signed_and_send_jito_tip

( recent_blockhash: anchor_client::solana_sdk::hash::Hash, keypair: &Keypair, mut instructions: Ve

src/domain/tx.rs:364

↓ 1 callersFunctionnew_signed_and_send_nozomi_tip

( recent_blockhash: anchor_client::solana_sdk::hash::Hash, keypair: &Keypair, mut instructions: Ve

src/domain/tx.rs:568

↓ 1 callersFunctionnew_signed_and_send_zeroslot_tip

( recent_blockhash: anchor_client::solana_sdk::hash::Hash, keypair: &Keypair, mut instructions: Ve

src/domain/tx.rs:667

↓ 1 callersMethodregister_meteora_dlmm

Register Meteora DLMM DEX

src/infrastructure/dex/dex_registry.rs:120

↓ 1 callersMethodregister_meteora_pools

Register Meteora Pools DEX

src/infrastructure/dex/dex_registry.rs:134

↓ 1 callersMethodregister_orca_whirlpool

Register Orca Whirlpool DEX

src/infrastructure/dex/dex_registry.rs:106

↓ 1 callersMethodregister_pumpswap

Register PumpSwap DEX

src/infrastructure/dex/dex_registry.rs:50

↓ 1 callersMethodregister_raydium_amm

Register Raydium AMM DEX

src/infrastructure/dex/dex_registry.rs:64

↓ 1 callersMethodregister_raydium_clmm

Register Raydium CLMM DEX

src/infrastructure/dex/dex_registry.rs:78

↓ 1 callersMethodregister_raydium_cpmm

Register Raydium CPMM DEX

src/infrastructure/dex/dex_registry.rs:92

↓ 1 callersMethodsend_request

(&self, method: &str, params: Value)

src/infrastructure/services/jito.rs:268

↓ 1 callersMethodsend_request

(&self, method: &str, params: Value)

src/infrastructure/services/zeroslot.rs:154

↓ 1 callersMethodtry_send_transaction

(&self, encoded_tx: &str)

src/infrastructure/services/jito.rs:243

↓ 1 callersMethodtry_send_transaction

(&self, encoded_tx: &str)

src/infrastructure/services/zeroslot.rs:132

↓ 1 callersFunctionupdate_last_message_time

Add this function to update the last message time

src/application/monitor.rs:184

↓ 1 callersFunctionwait_for_bundle_confirmation

( fetch_statuses: F, bundle_id: String, interval: Duration, timeout: Duration, )

src/infrastructure/services/jito.rs:91

Functioncopy_trader_pumpfun

( yellowstone_grpc_http: String, yellowstone_grpc_token: String, app_state: AppState, swap_con

src/application/monitor.rs:1393

(&self, message: String)

src/shared/logger.rs:28

src/infrastructure/services/jito.rs:184

src/infrastructure/services/zeroslot.rs:75

(&self, message: String)

src/shared/logger.rs:35

Methodfind_arbitrage_opportunities

Find arbitrage opportunities for a token

src/domain/token.rs:115

Functionfind_pools_for_token

Find pools for a token on a specific DEX

src/domain/token.rs:228

(&self, f: &mut std::fmt::Formatter<'_>)

src/error/mod.rs:98

(value: SwapDirection)

src/application/swap.rs:12

(error: SolanaClientError)

src/error/mod.rs:162

Methodfrom_json

(txn: SubscribeUpdateTransaction, log_messages: Vec<String>)

src/application/monitor.rs:209

Methodget_all_prices

Get all prices for a token across all DEXes

src/domain/token.rs:100

Methodget_all_token_mints

Get all token mints in the cache

src/application/pool_discovery.rs:92

Methodget_concentrated_liquidity_dexes

Get all DEXes that use concentrated liquidity

src/infrastructure/dex/dex_registry.rs:173

Methodget_constant_product_dexes

Get all DEXes that use constant product AMM

src/infrastructure/dex/dex_registry.rs:163

Get a DEX by name

src/infrastructure/dex/dex_registry.rs:153

Methodget_dex_pool_size

Get the pool account size for a DEX

src/domain/token.rs:110

Methodget_dex_program

Get the program ID for a DEX

src/domain/token.rs:105

Functionget_jito_tip

src/domain/tx.rs:58

Functionget_nozomi_tip

src/infrastructure/services/nozomi.rs:8

Methodget_pools_for_token

Get pools for a token

src/application/pool_discovery.rs:87

Methodget_price

Get price for a token on a specific DEX

src/domain/token.rs:94

Functionget_pumpfun_token_price

Get the price of a token from a PumpFun bonding curve

src/domain/token.rs:336

Functionget_pumpswap_token_price

Get the price of a token from a PumpSwap pool

src/domain/token.rs:260

next →1–100 of 134, ranked by callers