65227f44dc
* reimplement rpc pubsub with a broadcast queue * update tests for new pubsub implementation * fix: fix review suggestions * chore(rpc): add additional pubsub metrics * integrate max subscriptions check into SubscriptionTracker to reduce locking * separate subscription control from tracker * limit memory usage of items in pubsub broadcast queue, improve error handling * add more pubsub metrics * add final count metrics to pubsub * add metric for total number of subscriptions * fix small review suggestions * remove by_params from SubscriptionTracker and add node_progress_watchers map instead * add subscription tracker tests * add metrics for number of pubsub notifications as a counter * ignore clippy lint in TokenCounter * fix underflow in token counter * reduce queue capacity in pubsub tests * fix(rpc): fix test timeouts * fix race in account subscription test * Add RpcSubscriptions::new_for_tests Co-authored-by: Pavel Strakhov <p.strakhov@iconic.vc> Co-authored-by: Nikita Podoliako <n.podoliako@zubr.io> Co-authored-by: Tyera Eulberg <tyera@solana.com> |
||
|---|---|---|
| .. | ||
| cluster_tpu_info.rs | ||
| lib.rs | ||
| max_slots.rs | ||
| optimistically_confirmed_bank_tracker.rs | ||
| parsed_token_accounts.rs | ||
| rpc.rs | ||
| rpc_completed_slots_service.rs | ||
| rpc_health.rs | ||
| rpc_pubsub.rs | ||
| rpc_pubsub_service.rs | ||
| rpc_service.rs | ||
| rpc_subscription_tracker.rs | ||
| rpc_subscriptions.rs | ||
| transaction_status_service.rs | ||