Struct solana_core::rpc_subscriptions::RpcSubscriptions

[+] Show declaration

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_with_vote_subscription(
    exit: &Arc<AtomicBool>,
    bank_forks: Arc<RwLock<BankForks>>,
    block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>,
    optimistically_confirmed_bank: Arc<RwLock<OptimisticallyConfirmedBank>>,
    enable_vote_subscription: bool
) -> Self

pub fn default_with_bank_forks(bank_forks: Arc<RwLock<BankForks>>) -> Self

pub fn total(&self) -> usize

pub fn add_account_subscription(
    &self,
    pubkey: Pubkey,
    config: Option<RpcAccountInfoConfig>,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Response<UiAccount>>
)

pub fn remove_account_subscription(&self, id: &SubscriptionId) -> bool

pub fn add_program_subscription(
    &self,
    program_id: Pubkey,
    config: Option<RpcProgramAccountsConfig>,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Response<RpcKeyedAccount>>
)

pub fn remove_program_subscription(&self, id: &SubscriptionId) -> bool

pub fn add_logs_subscription(
    &self,
    address: Option<Pubkey>,
    include_votes: bool,
    commitment: Option<CommitmentConfig>,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Response<RpcLogsResponse>>
)

pub fn remove_logs_subscription(&self, id: &SubscriptionId) -> bool

pub fn add_signature_subscription(
    &self,
    signature: Signature,
    signature_subscribe_config: Option<RpcSignatureSubscribeConfig>,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Response<RpcSignatureResult>>
)

pub fn remove_signature_subscription(&self, id: &SubscriptionId) -> bool

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 add_slot_subscription(
    &self,
    sub_id: SubscriptionId,
    subscriber: Subscriber<SlotInfo>
)

pub fn remove_slot_subscription(&self, id: &SubscriptionId) -> bool

pub fn add_slots_updates_subscription(
    &self,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Arc<SlotUpdate>>
)

pub fn remove_slots_updates_subscription(&self, id: &SubscriptionId) -> bool

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

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

pub fn add_vote_subscription(
    &self,
    sub_id: SubscriptionId,
    subscriber: Subscriber<RpcVote>
)

pub fn remove_vote_subscription(&self, id: &SubscriptionId) -> bool

pub fn notify_vote(&self, vote: &Vote)

pub fn add_root_subscription(
    &self,
    sub_id: SubscriptionId,
    subscriber: Subscriber<Slot>
)

pub fn remove_root_subscription(&self, id: &SubscriptionId) -> bool

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

pub fn add_evm_block_subscription(
    &self,
    sub_id: SubscriptionId,
    subscriber: Subscriber<RPCBlock>
)

pub fn remove_evm_block_subscription(&self, id: &SubscriptionId) -> bool

pub fn notify_evm_block(&self, new_head: Block)

Trait Implementations

impl Drop for RpcSubscriptions[+]

[+] Show hidden undocumented items

fn drop(&mut self)[−]

Executes the destructor for this type.