blockworks-foundation
/
geyser-grpc-connector
mirror of https://github.com/blockworks-foundation/geyser-grpc-connector.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bench ONLY spl accounts

This commit is contained in:
GroovieGermanikus 2024-05-08 16:15:20 +02:00
parent 61b202af9f
commit 6ffc8d0f0d
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 9 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
examples/bench_geyser_grpc_accounts.rs
View File

@ -68,20 +68,20 @@ pub async fn main() {
// exit_notify.resubscribe(),
// );
let _all_accounts = create_geyser_autoconnection_task_with_mpsc(
config.clone(),
all_accounts(),
autoconnect_tx.clone(),
exit_notify.resubscribe(),
);
// let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc(
// let _all_accounts = create_geyser_autoconnection_task_with_mpsc(
// config.clone(),
// token_accounts(),
// all_accounts(),
// autoconnect_tx.clone(),
// exit_notify.resubscribe(),
// );
let _token_accounts_task = create_geyser_autoconnection_task_with_mpsc(
config.clone(),
token_accounts(),
autoconnect_tx.clone(),
exit_notify.resubscribe(),
);
let current_processed_slot = AtomicSlot::default();
start_tracking_slots(current_processed_slot.clone());
start_tracking_account_consumer(geyser_messages_rx, current_processed_slot.clone());
@ -282,19 +282,8 @@ pub fn token_accounts() -> SubscribeRequest {
},
);
let mut slots_subs = HashMap::new();
slots_subs.insert("client".to_string(), SubscribeRequestFilterSlots {
filter_by_commitment: Some(true),
});
let mut blocks_meta_subs = HashMap::new();
blocks_meta_subs.insert("client".to_string(), SubscribeRequestFilterBlocksMeta {});
SubscribeRequest {
slots: slots_subs,
accounts: accounts_subs,
blocks_meta: blocks_meta_subs,
..Default::default()
}
}