Struct solana_rpc::rpc_subscriptions::RpcSubscriptions

pub struct RpcSubscriptions { /* fields omitted */ }

Implementations

impl RpcSubscriptions

pub fn new(
    exit: &Arc<AtomicBool>,
    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>,
    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>,
    bank_forks: Arc<RwLock<BankForks>>,
    block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>,
    optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>>,
    config: &PubSubConfig
) -> Self

pub fn default_with_bank_forks(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: &Vote)

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.