MCPcopy Create free account

hub / github.com/WSOL12/Solana-Relayer / functions

Functions147 in github.com/WSOL12/Solana-Relayer

⨍ Functions 147◇ Types & classes 47
↓ 30 callersMethodlen
(&self)
relayer/src/auth_challenges.rs:70
↓ 10 callersMethodsend
(&self, serialized_txns: Vec<Vec<u8>>)
packet_blaster/src/main.rs:398
↓ 8 callersMethodjoin
(self)
core/src/tpu.rs:149
↓ 6 callersMethodhandle
(&self)
relayer/src/relayer.rs:476
↓ 5 callersMethodpush
(&self, ip: IpAddr, challenge: Reverse<AuthChallenge>)
relayer/src/auth_challenges.rs:65
↓ 3 callersMethodis_expired
(&self)
relayer/src/auth_challenges.rs:25
↓ 3 callersMethodrpc_client
Returns the server with the highest slot URL
rpc/src/load_balancer.rs:163
↓ 2 callersMethodcmp
(&self, other: &Self)
relayer/src/auth_challenges.rs:45
↓ 2 callersMethodget_priority
(&self, ip: &IpAddr)
relayer/src/auth_challenges.rs:75
↓ 2 callersFunctionis_aoi_in_lookup_table
For each lookup table, look at the writable_indexes and do a lookup in the address_lookup_table_cache to find the address. Then determine if in accoun
block_engine/src/block_engine.rs:739
↓ 2 callersFunctionis_aoi_in_static_keys
( tx: &VersionedTransaction, accounts_of_interest: &mut TimedCache<Pubkey, u8>, programs_of_intere
block_engine/src/block_engine.rs:721
↓ 2 callersFunctionis_tx_ofac_related
Returns true if transaction is ofac-related, false if not
core/src/ofac.rs:10
↓ 2 callersFunctionrefresh_address_lookup_table
( rpc_load_balancer: &Arc<LoadBalancer>, lookup_table: &DashMap<Pubkey, AddressLookupTableAccount>, )
transaction-relayer/src/main.rs:717
↓ 2 callersMethodremove
(&self, ip: &IpAddr)
relayer/src/auth_challenges.rs:80
↓ 2 callersFunctionshould_forward_tx
(tx_cache: &DashSet<String>, tx_signature: &str)
core/src/tx_cache.rs:3
↓ 1 callersFunctionbuild_relayer_router
Returns an axum router with endpoints to get status of relayer
web/src/lib.rs:48
↓ 1 callersMethodconnected_validators
(&self)
relayer/src/relayer.rs:391
↓ 1 callersMethodgenerate_auth_challenge
( &self, req: Request<GenerateAuthChallengeRequest>, )
relayer/src/auth_service.rs:148
↓ 1 callersMethodgenerate_auth_tokens
( &self, req: Request<GenerateAuthTokensRequest>, )
relayer/src/auth_service.rs:213
↓ 1 callersMethodget_highest_slot
(&self)
rpc/src/load_balancer.rs:173
↓ 1 callersFunctionget_sockets
(args: &Args)
transaction-relayer/src/main.rs:249
↓ 1 callersFunctiongraceful_panic
Returns an exit boolean to let other threads gracefully shut down
core/src/lib.rs:21
↓ 1 callersMethodincrement_packets_dropped
(&mut self, validator_id: &Pubkey, num_packets: u64)
relayer/src/relayer.rs:152
↓ 1 callersMethodincrement_packets_forwarded
(&mut self, validator_id: &Pubkey, num_packets: u64)
relayer/src/relayer.rs:142
↓ 1 callersMethodis_authorized
(&self, pubkey: &Pubkey)
transaction-relayer/src/main.rs:653
↓ 1 callersFunctionis_ofac_address_in_lookup_table
Returns true if an ofac address is in the dynamic keys (lookup table) for an account
core/src/ofac.rs:31
↓ 1 callersFunctionis_ofac_address_in_static_keys
Returns true if an ofac address is in the static keys for an account
core/src/ofac.rs:20
↓ 1 callersMethodis_scheduled_validator
(&self, pubkey: &Pubkey)
relayer/src/schedule_cache.rs:52
↓ 1 callersMethodjwt_from_header
( &self, meta: &MetadataMap, )
relayer/src/auth_interceptor.rs:79
↓ 1 callersFunctionlocal_socket_addr
Generates sequential localhost sockets on different IPs
packet_blaster/src/main.rs:117
↓ 1 callersFunctionpacket_to_proto_packet
(p: &Packet)
jito-protos/src/convert.rs:5
↓ 1 callersFunctionread_keypairs
(path: PathBuf)
packet_blaster/src/main.rs:101
↓ 1 callersMethodrefresh_access_token
( &self, req: Request<RefreshAccessTokenRequest>, )
relayer/src/auth_service.rs:325
↓ 1 callersMethodremove_all_expired
(&self)
relayer/src/auth_challenges.rs:54
↓ 1 callersMethodreport
(&self, thread_id: u64, delay: u32)
transaction-relayer/src/forwarder.rs:203
↓ 1 callersFunctionsend_post_request
(client: &Client, url: &String, payload: Vec<u8>)
explorer_engine/src/heartbeat_sender.rs:41
↓ 1 callersFunctionshutdown_signal
(exit: Arc<AtomicBool>)
transaction-relayer/src/main.rs:617
↓ 1 callersFunctionstart_forward_and_delay_thread
Forwards packets to the Block Engine handler thread. Delays transactions for packet_delay_ms before forwarding them to the validator.
transaction-relayer/src/forwarder.rs:21
↓ 1 callersFunctionstart_lookup_table_refresher
( rpc_load_balancer: &Arc<LoadBalancer>, lookup_table: &Arc<DashMap<Pubkey, AddressLookupTableAccount>
transaction-relayer/src/main.rs:661
↓ 1 callersFunctionstart_relayer_web_server
Starts the relayer webserver to serve HTTP requests against Note this is a blocking call, so call spawn in tokio
web/src/lib.rs:115
↓ 1 callersMethodupdate_block_engine_packet_sender_len
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:81
↓ 1 callersMethodupdate_max_len
( &mut self, slot_receiver_len: usize, subscription_receiver_len: usize, delay
relayer/src/relayer.rs:111
↓ 1 callersMethodupdate_queue_lengths
( &mut self, buffered_packet_batches_len: usize, buffered_packet_batches_capacity: usi
transaction-relayer/src/forwarder.rs:181
Methodauth
Relayers are whitelisted in the block engine. In order to auth, a challenge-response handshake is performed. After that, the relayer can fetch an acce
block_engine/src/block_engine.rs:170
Methodauth_and_connect
( block_engine_url: &str, auth_service_url: &str, block_engine_receiver: &mut Receiver
block_engine/src/block_engine.rs:221
Methodbroadcast
(&self, payload: Vec<u8>)
explorer_engine/src/heartbeat_sender.rs:33
Methodcall
(&mut self, mut req: Request<()>)
relayer/src/auth_interceptor.rs:124
Methodcall
(&mut self, mut request: tonic::Request<()>)
block_engine/src/block_engine.rs:72
Methodcheck_and_send_heartbeat
Checks the heartbeat timeout and errors out if the heartbeat didn't come in time. Assuming that's okay, sends a heartbeat back and if that fails, disc
block_engine/src/block_engine.rs:699
Methodcheck_health
Prevent validators from authenticating if the relayer is unhealthy
relayer/src/relayer.rs:790
Methodcheck_health
Prevent validators from authenticating if the relayer is unhealthy
relayer/src/auth_service.rs:137
Methodclient_ip
NOTE: if this is behind a proxy, the remote_addr will be the proxy, which may mess with the authentication scheme
relayer/src/auth_service.rs:121
Methodconnect_and_run
( explorer_engine_receiver: &mut Receiver<BlockEnginePackets>, restart_interval: Duration,
explorer_engine/src/explorer_engine.rs:157
Methodconnect_to_engine
(engine_url: &str)
explorer_engine/src/explorer_engine.rs:272
Methodcreate_endpoint
source taken from https://github.com/solana-labs/solana/blob/527e2d4f59c6429a4a959d279738c872b97e56b5/client/src/nonblocking/quic_client.rs#L93 origin
packet_blaster/src/main.rs:299
Methoddrop_connections
( disconnected_pubkeys: Vec<Pubkey>, subscriptions: &PacketSubscriptions, relayer_metr
relayer/src/relayer.rs:587
Methodeq
(&self, other: &Self)
relayer/src/auth_challenges.rs:33
Methodfilter_packets
Filters out packets that aren't on list of interest
block_engine/src/block_engine.rs:634
Methodfind_closest_engine
()
explorer_engine/src/explorer_engine.rs:268
Methodforward_packets
Returns pubkeys of subscribers that failed to send
relayer/src/relayer.rs:639
Methodforward_packets
( stream: Arc<Mutex<OwnedWriteHalf>>, data: &[u8], )
explorer_engine/src/explorer_engine.rs:288
Methodforward_packets
Forwards packets to the Block Engine
block_engine/src/block_engine.rs:612
Methodfrom
(de_ser_claims: &DeSerClaims)
relayer/src/auth_interceptor.rs:32
Methodgenerate_challenge_token
()
relayer/src/auth_service.rs:128
Functionget_health
Returns a simple string for relayer health
web/src/lib.rs:58
Functionget_status
Returns the status of different components inside the relayer
web/src/lib.rs:74
Methodget_tpu_configs
Validator calls this to get the public IP of the relayers TPU and TPU forward sockets.
relayer/src/relayer.rs:809
Methodhandle
Gets a handle to a constantly updating leader schedule handler
relayer/src/schedule_cache.rs:75
Methodhandle
Return a handle to the health manager state
relayer/src/health_manager.rs:82
Methodhandle_aoi
( maybe_msg: Result<Option<AccountsOfInterestUpdate>, Status>, accounts_of_interest: &mut Time
block_engine/src/block_engine.rs:557
Methodhandle_forwarded_packets
Copies tpu_forward packets to tpu channel. marks as forwarded
core/src/fetch_stage.rs:92
Methodhandle_heartbeat
( subscriptions: &PacketSubscriptions, relayer_metrics: &mut RelayerMetrics, )
relayer/src/relayer.rs:606
Methodhandle_packet_stream
( block_engine_packet_sender: Sender<PacketBatchUpdate>, block_engine_receiver: &mut Receiver<
block_engine/src/block_engine.rs:355
Methodhandle_poi
( maybe_msg: Result<Option<ProgramsOfInterestUpdate>, Status>, programs_of_interest: &mut Time
block_engine/src/block_engine.rs:584
Methodhandle_subscription
( maybe_subscription: Result<Subscription, RecvError>, subscriptions: &PacketSubscriptions,
relayer/src/relayer.rs:747
Functionhomepage
(Extension(_state): Extension<Arc<RelayerState>>)
web/src/lib.rs:53
Methodincrement_accounts_of_interest_len
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:102
Methodincrement_aoi_accounts_received
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:49
Methodincrement_aoi_update_count
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:45
Methodincrement_aoi_update_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:53
Methodincrement_auth_refresh_count
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:86
Methodincrement_flush_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:110
Methodincrement_heartbeat_count
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:37
Methodincrement_heartbeat_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:41
Methodincrement_metrics_delay_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:98
Methodincrement_num_packets_received
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:69
Methodincrement_packet_filter_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:73
Methodincrement_packet_forward_count
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:94
Methodincrement_packet_forward_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:77
Methodincrement_poi_accounts_received
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:61
Methodincrement_poi_update_count
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:57
Methodincrement_poi_update_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:65
Methodincrement_programs_of_interest_len
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:106
Methodincrement_refresh_auth_elapsed_us
(&mut self, num: u64)
block_engine/src/block_engine_stats.rs:90
Methodis_expired
(&self)
relayer/src/auth_interceptor.rs:25
Methodjoin
(self)
relayer/src/schedule_cache.rs:79
Methodjoin
(self)
relayer/src/relayer.rs:798
Methodjoin
(self)
relayer/src/health_manager.rs:86
Methodjoin
(self)
core/src/staked_nodes_updater_service.rs:91
Methodjoin
(self)
core/src/fetch_stage.rs:124
next →1–100 of 147, ranked by callers