MCPcopy Create free account

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

Functions147 in github.com/WSOL12/Solana-Relayer

⨍ Functions 147◇ Types & classes 47
Methodjoin
(self)
explorer_engine/src/explorer_engine.rs:295
Methodjoin
(self)
rpc/src/load_balancer.rs:183
Methodjoin
(self)
block_engine/src/block_engine.rs:161
Methodleader_for_slot
(&self, slot: &Slot)
relayer/src/schedule_cache.rs:40
Methodleaders_for_slots
(&self, slots: &[Slot])
relayer/src/schedule_cache.rs:44
Functionmain
()
packet_blaster/src/main.rs:138
Functionmain
()
jito-protos/build.rs:3
Functionmain
()
transaction-relayer/src/main.rs:311
Methodmaybe_refresh_auth
Refresh authentication tokens if they're about to expire
block_engine/src/block_engine.rs:484
Methodnew
()
packet_blaster/src/main.rs:265
Methodnew
(schedule: Arc<RwLock<HashMap<Slot, Pubkey>>>)
relayer/src/schedule_cache.rs:36
Methodnew
( verifying_key: Arc<PKeyWithDigest<Public>>, expected_signing_algo: AlgorithmType, )
relayer/src/auth_interceptor.rs:69
Methodnew
( slot_receiver_capacity: usize, subscription_receiver_capacity: usize, delay_packet_r
relayer/src/relayer.rs:80
Methodnew
( validator_auther: V, signing_key: PKeyWithDigest<Private>, verifying_key: Arc<PKeyWi
relayer/src/auth_service.rs:73
Methodnew
( slot_receiver: Receiver<Slot>, slot_sender: Sender<Slot>, missing_slot_unhealthy_thr
relayer/src/health_manager.rs:29
Methodnew
( sockets: TpuSockets, exit: &Arc<AtomicBool>, keypair: &Keypair, tpu_ip: &IpA
core/src/tpu.rs:50
Methodnew
( exit: Arc<AtomicBool>, rpc_load_balancer: Arc<LoadBalancer>, shared_staked_nodes: Ar
core/src/staked_nodes_updater_service.rs:25
Methodnew
( tpu_forwards_receiver: PacketBatchReceiver, tpu_sender: PacketBatchSender, exit: Arc
core/src/fetch_stage.rs:35
Methodnew
Encapsulate a TcpStream with reader functionality
explorer_engine/src/explorer_engine.rs:72
Methodnew
(urls: Vec<String>)
explorer_engine/src/heartbeat_sender.rs:14
Methodnew
( servers: &[(String, String)], /* http rpc url, ws url */ exit: &Arc<AtomicBool>, )
rpc/src/load_balancer.rs:33
Methodnew
(access_token: Arc<Mutex<Token>>)
block_engine/src/block_engine.rs:66
Methodnew
( slot_health: Arc<RwLock<HealthState>>, is_connected_to_block_engine: &Arc<AtomicBool>,
web/src/lib.rs:27
Methodnew
( buffered_packet_batches_capacity: usize, verified_receiver_capacity: usize, block_en
transaction-relayer/src/forwarder.rs:160
Methodpartial_cmp
(&self, other: &Self)
relayer/src/auth_challenges.rs:39
Methodread_from_bufreader
(reader: &mut BufReader<OwnedReadHalf>)
explorer_engine/src/explorer_engine.rs:83
Methodread_message
(&mut self)
explorer_engine/src/explorer_engine.rs:90
Methodread_u16_from_bufreader
(reader: &mut BufReader<OwnedReadHalf>)
explorer_engine/src/explorer_engine.rs:77
Methodrefresh_thread
( schedule: Arc<RwLock<HashMap<Slot, Pubkey>>>, load_balancer: Arc<LoadBalancer>, exit
relayer/src/schedule_cache.rs:83
Methodreport
(&self)
relayer/src/relayer.rs:162
Methodreport
(&self)
block_engine/src/block_engine_stats.rs:114
Functionrequest_and_confirm_airdrop
( client: &RpcClient, pubkeys: &[Pubkey], )
packet_blaster/src/main.rs:452
Methodrun_event_loop
( slot_receiver: Receiver<Slot>, subscription_receiver: Receiver<Subscription>, delay_
relayer/src/relayer.rs:481
Methodsetup_quinn_sender
( dest_addr: SocketAddr, ip_port_offset: u16, thread_id: usize, spam_from_loca
packet_blaster/src/main.rs:377
Methodstart_challenge_expiration_task
( auth_challenges: AuthChallenges, sleep_interval: StdDuration, exit: &Arc<AtomicBool>
relayer/src/auth_service.rs:104
Methodstart_event_loop
( explorer_engine_receiver: &mut Receiver<BlockEnginePackets>, explorer_engine_stream: TcpStre
explorer_engine/src/explorer_engine.rs:177
Methodstart_event_loop
( mut client: BlockEngineRelayerClient<InterceptedService<Channel, AuthInterceptor>>, block_en
block_engine/src/block_engine.rs:306
Methodstart_subscription_threads
( servers: &[(String, String)], server_to_slot: Arc<DashMap<String, Slot>>, slot_sende
rpc/src/load_balancer.rs:71
Methodsubscribe_packets
Validator calls this to subscribe to packets
relayer/src/relayer.rs:830
Functiontest_discard_ofac_packets
()
core/src/ofac.rs:258
Functiontest_is_ofac_address_in_lookup_table
()
core/src/ofac.rs:160
Functiontest_is_ofac_address_in_static_keys
()
core/src/ofac.rs:78
Methodtry_refresh_pk_to_stake
( last_stakes: &mut Instant, pubkey_stake_map: &mut Arc<HashMap<Pubkey, u64>>, rpc_loa
core/src/staked_nodes_updater_service.rs:60
Methodupdate_highest_slot
( maybe_slot: Result<u64, RecvError>, highest_slot: &mut Slot, relayer_metrics: &mut R
relayer/src/relayer.rs:778
Methodupdate_leader_cache
( load_balancer: &Arc<LoadBalancer>, schedule: &Arc<RwLock<HashMap<Slot, Pubkey>>>, )
relayer/src/schedule_cache.rs:116
Methodupdate_packet_subscription_total_capacity
( &mut self, packet_subscriptions: &HashMap< Pubkey, TokioSender<Resul
relayer/src/relayer.rs:128
Methodverify_server_cert
( &self, _end_entity: &rustls::Certificate, _intermediates: &[rustls::Certificate],
packet_blaster/src/main.rs:271
← previous101–147 of 147, ranked by callers