Functions — github.com/Jayant818/sol-indexer

hub / github.com/Jayant818/sol-indexer / functions

Functions74 in github.com/Jayant818/sol-indexer

⨍ Functions 74 ◇ Types & classes 37

↓ 39 callersMethodlen

(&self)

src/infrastructure/buffer/memory.rs:37

↓ 8 callersMethodis_empty

(&self)

src/infrastructure/buffer/memory.rs:41

↓ 4 callersFunctionsendInstructions

({ payer, instructions, }: { payer: KeyPairSigner; instructions: Instruction[]; })

scripts/src/simulateTokenTransfer.ts:37

↓ 3 callersMethodproduce

(&self, event:ChainEvent)

src/infrastructure/buffer/memory.rs:24

↓ 2 callersFunctioncreateATA

( payer: KeyPairSigner, mintAddress: Address )

scripts/src/simulateTokenTransfer.ts:97

↓ 2 callersMethodparse

(&self, txn: SolanaTransaction)

src/adapters/parsers/Jupiter_vixen.rs:380

↓ 2 callersMethodparse

(&self, txn:SolanaTransaction)

src/adapters/parsers/pump_fun.rs:257

↓ 1 callersMethodamount_in

(&self)

src/domain/models.rs:33

↓ 1 callersMethodconnect

(endpoint:String,x_token:Option<String>)

src/adapters/inbound/grpc_source.rs:18

↓ 1 callersFunctioncreateMint

(payer: KeyPairSigner)

scripts/src/simulateTokenTransfer.ts:69

↓ 1 callersMethodfind_sol_transfer_from

Find SOL transfers in inner instructions. For Buy: user pays SOL (look for transfers FROM user) For Sell: user receives SOL (look for transfers TO use

src/adapters/parsers/pump_fun.rs:26

↓ 1 callersMethodformat_jupiter_message

(&self, swap: &JupiterSwapEvent)

src/adapters/outbound/telegram.rs:49

↓ 1 callersMethodformat_message

(&self, swap: &SwapEvent)

src/adapters/outbound/telegram.rs:100

↓ 1 callersMethodformat_pumpfun_message

(&self, trade: &crate::domain::PumpFunTrade)

src/adapters/outbound/telegram.rs:78

↓ 1 callersMethodformat_raydium_message

(&self, swap: &RaydiumSwapEvent)

src/adapters/outbound/telegram.rs:32

↓ 1 callersMethodget_last_slot

(&self)

src/adapters/outbound/postgres.rs:37

↓ 1 callersFunctionmain

()

scripts/src/simulateTokenTransfer.ts:168

↓ 1 callersFunctionmap_rpx_tx

(tx:EncodedTransactionWithStatusMeta,slot:u64,block_time:i64)

src/adapters/inbound/rpc_source.rs:69

↓ 1 callersFunctionmintTokens

( ataAddress: Address, mintAuthority: KeyPairSigner, mintAddress: Address )

scripts/src/simulateTokenTransfer.ts:152

↓ 1 callersMethodnext_event

(&mut self)

src/adapters/inbound/grpc_source.rs:82

↓ 1 callersMethodrun

(&mut self)

src/application/use_cases/ingest.rs:22

↓ 1 callersMethodsend_swap_alert

(&self,swap:&SwapEvent)

src/adapters/outbound/telegram.rs:111

↓ 1 callersFunctiontransferToken

({ userA_ata, userB_ata, userA, mintAddress, counter, }: { userA_ata: Address; userB_ata: Addres

scripts/src/simulateTokenTransfer.ts:120

Methodcalculate_sol_received

Calculate SOL received by user from pre/post balance changes This is needed for Sell because Pump.fun doesn't use System Program Transfer

src/adapters/parsers/pump_fun.rs:71

Methodconvert_protobuf_inner_instruction

Convert gRPC inner instructions to Vixen InstructionUpdates

src/adapters/parsers/vixen_utils.rs:12

Methodconvert_protobuf_inner_instruction

( inner_ixs:&Vec<InnerInstruction>, all_accounts: &Vec<Pubkey>, shared:Arc<Instruction

src/adapters/parsers/Jupiter_vixen.rs:107

Methodconvert_rpc_inner_instruction

Convert RPC inner instruction to Vixen InstructionUpdate

src/adapters/parsers/vixen_utils.rs:45

Methodconvert_rpc_inner_instruction

( ui_ix: &UiInstruction, all_accounts: &[Pubkey], shared: Arc<InstructionShared>,

src/adapters/parsers/Jupiter_vixen.rs:54

Methodconvert_token_balances_grpc

Convert gRPC token balances to RPC-style OptionSerializer format

src/adapters/parsers/vixen_utils.rs:135

Methodextract_accounts_from_grpc

Reconstruct all accounts from gRPC message and loaded addresses

src/adapters/parsers/vixen_utils.rs:196

Methodfind_cpi_amount_grpc

( parent_ix_idx:usize, target_dest_acc_idx:usize, inner_instructions: &[yellowstone_gr

src/adapters/parsers/raydium_amm.rs:204

Methodfind_cpi_amount_rpc

( parent_ix_id:usize, target_dest_acc_idx:usize, inner_instructions: &OptionSerializer

src/adapters/parsers/raydium_amm.rs:242

Methodfind_sol_transfer_to

(&self, inner_ixs: &[InstructionUpdate], to: &yellowstone_vixen_parser::Pubkey)

src/adapters/parsers/pump_fun.rs:47

Extract mint address from token account using pre_token_balances

src/adapters/parsers/vixen_utils.rs:170

Methodget_state

(&self)

src/adapters/outbound/postgres.rs:26

(vixen_plan: Vec<jupiter_v6::RoutePlanStep>)

src/adapters/parsers/Jupiter_vixen.rs:137

Methodname

(&self)

src/adapters/parsers/Jupiter_vixen.rs:378

Methodname

(&self)

src/adapters/parsers/raydium_amm.rs:309

Methodname

(&self)

src/adapters/parsers/spl_token.rs:266

Methodname

(&self)

src/adapters/parsers/pump_fun.rs:255

Methodnew

(capacity:usize)

src/infrastructure/buffer/memory.rs:12

Methodnew

()

src/adapters/parsers/Jupiter_vixen.rs:19

Methodnew

()

src/adapters/parsers/raydium_amm.rs:20

Methodnew

()

src/adapters/parsers/spl_token.rs:24

Methodnew

()

src/adapters/parsers/pump_fun.rs:19

Methodnew

(max_count:u64)

src/adapters/inbound/file_source.rs:17

Methodnew

(url:&str)

src/adapters/outbound/postgres.rs:13

Methodnew

(bot_token:String,chat_id_str:String)

src/adapters/outbound/telegram.rs:13

Methodnew

(rx:mpsc::Receiver<ChainEvent>,repo:Arc<dyn TransactionRepository>,parsers:Vec<Box<dyn TransactionParser>>, no

src/application/use_cases/ingest.rs:18

Methodnew

(notifier: Arc<dyn Notifier>, threshold_amount:u64)

src/application/services/notification.rs:12

Methodnext_event

(&mut self)

src/adapters/inbound/file_source.rs:27

Methodparse

(&self, txn:SolanaTransaction)

src/adapters/parsers/raydium_amm.rs:313

Methodparse

(&self, txn: SolanaTransaction)

src/adapters/parsers/spl_token.rs:268

Methodparse_instruction_data

(data:&[u8])

src/adapters/parsers/_jupiter.rs:57

Methodparse_protobuf

(&self, raw_bytes: &[u8],block_time:i64)

src/adapters/parsers/Jupiter_vixen.rs:149

Methodparse_protobuf

(&self,raw_bytes:&[u8],block_time:i64)

src/adapters/parsers/raydium_amm.rs:22

Methodparse_protobuf

(raw_bytes:&[u8])

src/adapters/parsers/spl_token.rs:26

Methodparse_protobuf

(&self, raw_bytes: &[u8],block_time:i64)

src/adapters/parsers/pump_fun.rs:81

Methodparse_rpc

(&self, tx: VersionedTransaction, meta: UiTransactionStatusMeta, slot: u64, signature: &str,block_time:i64)

src/adapters/parsers/Jupiter_vixen.rs:290

Methodparse_rpc

(&self,tx:VersionedTransaction,meta:UiTransactionStatusMeta,slot: u64,signature: &str,)

src/adapters/parsers/raydium_amm.rs:122

Methodparse_rpc

(&self, tx: &VersionedTransaction, meta: &UiTransactionStatusMeta, slot: u64, sig: &str)

src/adapters/parsers/_jupiter.rs:73

Methodparse_rpc

(tx: &VersionedTransaction, meta: &UiTransactionStatusMeta, slot: u64, sig: &str)

src/adapters/parsers/spl_token.rs:140

Methodresolve_mint_grpc

( account_idx: usize, pre: &[TokenBalance], post: &[TokenBalance], )

src/adapters/parsers/raydium_amm.rs:293

Methodresolve_mint_rpc

( account_idx:usize, pre: &[UiTransactionTokenBalance], post: &[UiTransactionTokenBala

src/adapters/parsers/raydium_amm.rs:279

Functionrun_backfill_producer

This function does one thing: it wakes up, fetches data, puts it in the buffer, and dies.

src/adapters/inbound/rpc_source.rs:8

Methodsave_batch

(&self,transaction_event:&[TransactionEvent],current_slot:u64)

src/adapters/outbound/postgres.rs:48

Methodsave_dlq

(&self,txn:&SolanaTransaction,parser_name:&str,error:&str)

src/adapters/outbound/postgres.rs:192

Methodsend_to_queue

(&self,swap:&SwapEvent)

src/application/services/notification.rs:36

Methodshort_key

(&self, key: &str)

src/adapters/outbound/telegram.rs:28

Methodsignature

(&self)

src/domain/models.rs:41

Methodto_vixen_update_rpc

Build Vixen InstructionUpdate for RPC path

src/adapters/parsers/vixen_utils.rs:98

Methodto_vixen_update_rpc

Helper for RPC (Backfill) path

src/adapters/parsers/Jupiter_vixen.rs:22