Struct solana_core::tvu::Tvu

pub struct Tvu { /* fields omitted */ }

Implementations

impl Tvu

pub fn new(
    vote_account: &Pubkey,
    authorized_voter_keypairs: Vec<Arc<Keypair>>,
    bank_forks: &Arc<RwLock<BankForks>>,
    cluster_info: &Arc<ClusterInfo>,
    sockets: Sockets,
    blockstore: Arc<Blockstore>,
    ledger_signal_receiver: Receiver<bool>,
    subscriptions: &Arc<RpcSubscriptions>,
    poh_recorder: &Arc<Mutex<PohRecorder>>,
    tower: Tower,
    leader_schedule_cache: &Arc<LeaderScheduleCache>,
    exit: &Arc<AtomicBool>,
    completed_slots_receiver: CompletedSlotsReceiver,
    block_commitment_cache: Arc<RwLock<BlockCommitmentCache>>,
    cfg: Option<Arc<AtomicBool>>,
    transaction_status_sender: Option<TransactionStatusSender>,
    rewards_recorder_sender: Option<RewardsRecorderSender>,
    cache_block_time_sender: Option<CacheBlockTimeSender>,
    evm_block_recorder_sender: Option<EvmRecorderSender>,
    snapshot_config_and_pending_package: Option<(SnapshotConfig, PendingSnapshotPackage)>,
    vote_tracker: Arc<VoteTracker>,
    retransmit_slots_sender: CrossbeamSender<HashMap<Slot, Arc<Bank>>>,
    verified_vote_receiver: VerifiedVoteReceiver,
    replay_vote_sender: ReplayVoteSender,
    completed_data_sets_sender: CompletedDataSetsSender,
    bank_notification_sender: Option<BankNotificationSender>,
    tvu_config: TvuConfig,
    max_slots: &Arc<MaxSlots>
) -> Self

This service receives messages from a leader in the network and processes the transactions on the bank state.

Arguments

• cluster_info - The cluster_info state.
• sockets - fetch, repair, and retransmit sockets
• blockstore - the ledger itself

pub fn join(self) -> Result<()>