Functions — github.com/RohanKapurDEV/mev-base

hub / github.com/RohanKapurDEV/mev-base / functions

Functions46 in github.com/RohanKapurDEV/mev-base

⨍ Functions 46 ◇ Types & classes 20

↓ 3 callersMethodpubkey

(&self)

lib/geyser-client/src/types.rs:38

↓ 3 callersMethodseq

(&self)

lib/geyser-client/src/types.rs:44

↓ 2 callersFunctionextract_highest_write_slot_header

(resp: &Response<T>)

lib/geyser-client/src/geyser_consumer.rs:361

↓ 1 callersMethodcurrent_slot

(&self)

lib/searcher-client/src/cluster_data_impl.rs:178

↓ 1 callersMethodnext_jito_validator

(&self)

lib/searcher-client/src/cluster_data_impl.rs:182

↓ 1 callersFunctionproto_packet_from_versioned_tx

Converts a VersionedTransaction to a protobuf packet

lib/searcher-client/src/convert.rs:127

↓ 1 callersMethodset_seq

(&mut self, seq: u64)

lib/geyser-client/src/types.rs:41

↓ 1 callersMethodslot

(&self)

lib/geyser-client/src/types.rs:47

↓ 1 callersFunctionslot_subscribe_loop

Maintains a RPC subscription to keep track of the current slot.

lib/searcher-client/src/cluster_data_impl.rs:209

↓ 1 callersFunctionversioned_tx_from_packet

Converts a protobuf packet to a VersionedTransaction

lib/searcher-client/src/convert.rs:115

Methodauth

( auth_service_client: &mut AuthServiceClient<Channel>, keypair: &Keypair, role: Role,

lib/searcher-client/src/client_interceptor.rs:55

Methodcall

(&mut self, mut request: Request<()>)

lib/searcher-client/src/client_interceptor.rs:157

Methodcall

(&mut self, mut request: tonic::Request<()>)

lib/geyser-client/src/interceptor.rs:9

Functionconnect

( geyser_addr: String, access_token: String, tls_config: Option<ClientTlsConfig>, exit: Arc<At

lib/geyser-client/src/lib.rs:18

Methodconsume_account_updates

( &self, account_updates_tx: UnboundedSender<AccountUpdate>, highest_rooted_slot: Arc<

lib/geyser-client/src/geyser_consumer.rs:103

Methodconsume_partial_account_updates

( &self, partial_account_updates_tx: UnboundedSender<PartialAccountUpdate>, highest_ro

lib/geyser-client/src/geyser_consumer.rs:153

Methodconsume_slot_updates

( &self, slot_updates_tx: UnboundedSender<SlotUpdate>, )

lib/geyser-client/src/geyser_consumer.rs:216

Methodcurrent_slot_updater

( current_slot: Arc<AtomicU64>, mut slot_receiver: Receiver<Slot>, exit: Arc<AtomicBoo

lib/searcher-client/src/cluster_data_impl.rs:86

Functionderive_tip_accounts

(tip_program_pubkey: &Pubkey)

lib/searcher-client/src/lib.rs:275

Methodfetch_connected_leaders_with_retries

( searcher_service_client: &mut SearcherServiceClient< InterceptedService<Channel, ClientI

lib/searcher-client/src/cluster_data_impl.rs:158

Methodfrom

(value: StoredExtendedReward)

lib/geyser-protos/src/lib.rs:45

Methodfrom

(rewards: Vec<Reward>)

lib/geyser-protos/src/convert.rs:38

Methodfrom

(proto: geyser::AccountUpdate)

lib/geyser-client/src/types.rs:53

Functiongrpc_connect

(url: &str)

lib/searcher-client/src/lib.rs:260

Methodjito_leader_schedule_cache_updater

( jito_leader_schedule_cache: JitoLeaderScheduleCache, current_slot: Arc<AtomicU64>, m

lib/searcher-client/src/cluster_data_impl.rs:105

Functionmain

()

lib/geyser-protos/build.rs:3

Functionmain

()

lib/searcher-protos/build.rs:3

Methodnew

( cluster_data: C, searcher_service_client: SearcherServiceClient<T>, exit: Arc<Atomic

lib/searcher-client/src/lib.rs:91

Methodnew

( mut auth_service_client: AuthServiceClient<Channel>, keypair: &Arc<Keypair>, )

lib/searcher-client/src/client_interceptor.rs:32

Methodnew

Creates a new instance of this object; also spawns a few background tokio tasks.

lib/searcher-client/src/cluster_data_impl.rs:49

Methodnew

( client: GeyserClient<InterceptedService<Channel, GrpcInterceptor>>, exit: Arc<AtomicBool>,

lib/geyser-client/src/geyser_consumer.rs:96

Functionpacket_batches_to_proto_packets

( batches: &[PacketBatch], )

lib/searcher-client/src/convert.rs:40

Functionpacket_to_proto_packet

Converts a Solana packet to a protobuf packet NOTE: the packet.data() function will filter packets marked for discard

lib/searcher-client/src/convert.rs:21

Methodprocess_account_update

( maybe_message: std::result::Result<Option<TimestampedAccountUpdate>, Status>, account_write_

lib/geyser-client/src/geyser_consumer.rs:246

Methodprocess_partial_account_update

( maybe_message: std::result::Result<Option<MaybePartialAccountUpdate>, Status>, account_write

lib/geyser-client/src/geyser_consumer.rs:275

Methodprocess_update

( update: &mut A, account_write_sequences: &mut AccountWriteSeqsCache, highest_rooted_

lib/geyser-client/src/geyser_consumer.rs:311

Functionproto_packet_batch_to_packets

( packet_batch: ProtoPacketBatch, )

lib/searcher-client/src/convert.rs:80

Functionproto_packet_to_packet

converts from a protobuf packet to packet

lib/searcher-client/src/convert.rs:51

Methodsend_bundle

Sends the list of transactions as a bundle iff the leader is a jito-solana. Returns the bundle's id.

lib/searcher-client/src/lib.rs:105

Methodsend_transactions

Sends transactions through the normal pipeline, regardless of if the leader is running jito-solana. Returns a list of results corresponding to the sup

lib/searcher-client/src/lib.rs:143

Methodsubscribe_bundle_results

( &self, buffer_size: usize, )

lib/searcher-client/src/lib.rs:218

Methodsubscribe_mempool_accounts

( &self, accounts: &[Pubkey], buffer_size: usize, )

lib/searcher-client/src/lib.rs:164

Functiontest_proto_to_packet

()

lib/searcher-client/src/convert.rs:149

Methodtoken_refresh_loop

( mut auth_service_client: AuthServiceClient<Channel>, bearer_token: Arc<RwLock<String>>,

lib/searcher-client/src/client_interceptor.rs:83

Methodtry_from

(value: TransactionStatusMeta)

lib/geyser-protos/src/lib.rs:231

Methodtry_from

( confirmed_block: confirmed_block::ConfirmedBlock, )

lib/geyser-protos/src/convert.rs:142