f14365f4b4
Use bulk insertion to Postgres at startup to reduce time taken for initial snapshot restore for postgres plugin. Avoid duplicate writes of accounts at startup. Doing account plugin notification and indexing in parallel. Improved error handling for postgres plugin to show the real db issues for debug purpose Added more metrics for postgres plugin. Refactored plugin centric code out to a sub module from accounts_db and added unit tests
29 lines
1.2 KiB
Rust
29 lines
1.2 KiB
Rust
use {
|
|
crate::append_vec::StoredAccountMeta,
|
|
solana_sdk::{account::AccountSharedData, clock::Slot, pubkey::Pubkey},
|
|
std::sync::{Arc, RwLock},
|
|
};
|
|
|
|
pub trait AccountsUpdateNotifierInterface: std::fmt::Debug {
|
|
/// Notified when an account is updated at runtime, due to transaction activities
|
|
fn notify_account_update(&self, slot: Slot, pubkey: &Pubkey, account: &AccountSharedData);
|
|
|
|
/// Notified when the AccountsDb is initialized at start when restored
|
|
/// from a snapshot.
|
|
fn notify_account_restore_from_snapshot(&self, slot: Slot, account: &StoredAccountMeta);
|
|
|
|
/// Notified when all accounts have been notified when restoring from a snapshot.
|
|
fn notify_end_of_restore_from_snapshot(&self);
|
|
|
|
/// Notified when a slot is optimistically confirmed
|
|
fn notify_slot_confirmed(&self, slot: Slot, parent: Option<Slot>);
|
|
|
|
/// Notified when a slot is marked frozen.
|
|
fn notify_slot_processed(&self, slot: Slot, parent: Option<Slot>);
|
|
|
|
/// Notified when a slot is rooted.
|
|
fn notify_slot_rooted(&self, slot: Slot, parent: Option<Slot>);
|
|
}
|
|
|
|
pub type AccountsUpdateNotifier = Arc<RwLock<dyn AccountsUpdateNotifierInterface + Sync + Send>>;
|