Struct solana_rpc::rpc_subscriptions::RpcSubscriptions

pub struct RpcSubscriptions { /* private fields */ }

Implementations

impl RpcSubscriptions

pub fn new( exit: Arc<AtomicBool>, max_complete_transaction_status_slot: Arc<AtomicU64>, max_complete_rewards_slot: Arc<AtomicU64>, blockstore: Arc<Blockstore>, bank_forks: Arc<RwLock<BankForks>>, block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>, optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>> ) -> Self

pub fn new_for_tests( exit: Arc<AtomicBool>, max_complete_transaction_status_slot: Arc<AtomicU64>, max_complete_rewards_slot: Arc<AtomicU64>, bank_forks: Arc<RwLock<BankForks>>, block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>, optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>> ) -> Self

pub fn new_for_tests_with_blockstore( exit: Arc<AtomicBool>, max_complete_transaction_status_slot: Arc<AtomicU64>, max_complete_rewards_slot: Arc<AtomicU64>, blockstore: Arc<Blockstore>, bank_forks: Arc<RwLock<BankForks>>, block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>, optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>> ) -> Self

pub fn new_with_config( exit: Arc<AtomicBool>, max_complete_transaction_status_slot: Arc<AtomicU64>, max_complete_rewards_slot: Arc<AtomicU64>, blockstore: Arc<Blockstore>, bank_forks: Arc<RwLock<BankForks>>, block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>, optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>>, config: &PubSubConfig, rpc_notifier_ready: Option<Arc<AtomicBool>> ) -> Self

pub fn default_with_bank_forks( max_complete_transaction_status_slot: Arc<AtomicU64>, max_complete_rewards_slot: Arc<AtomicU64>, bank_forks: Arc<RwLock<BankForks>> ) -> Self

pub fn control(&self) -> &SubscriptionControl

pub fn notify_subscribers(&self, commitment_slots: CommitmentSlots)

Notify subscribers of changes to any accounts or new signatures since the bank’s last checkpoint.

pub fn notify_gossip_subscribers(&self, slot: Slot)

Notify Confirmed commitment-level subscribers of changes to any accounts or new signatures.

pub fn notify_slot_update(&self, slot_update: SlotUpdate)

pub fn notify_slot(&self, slot: Slot, parent: Slot, root: Slot)

pub fn notify_signatures_received( &self, slot_signatures: (Slot, Vec<Signature>) )

pub fn notify_vote( &self, vote_pubkey: Pubkey, vote: VoteTransaction, signature: Signature )

pub fn notify_roots(&self, rooted_slots: Vec<Slot>)

Trait Implementations

impl Drop for RpcSubscriptions

fn drop(&mut self)

Executes the destructor for this type.