Struct TransactionPool

pub struct TransactionPool {
    pub pool: IndexedPool,
    locally_generated_uncommitted: HashMap<ValidCommandWithHash, (Timestamp, Batch)>,
    locally_generated_committed: HashMap<ValidCommandWithHash, (Timestamp, Batch)>,
    current_batch: usize,
    remaining_in_batch: usize,
    pub config: Config,
    batcher: (),
    best_tip_diff_relay: Option<()>,
    verification_key_table: VkRefcountTable,
}

Fields

pool: IndexedPool

locally_generated_uncommitted: HashMap<ValidCommandWithHash, (Timestamp, Batch)>

locally_generated_committed: HashMap<ValidCommandWithHash, (Timestamp, Batch)>

current_batch: usize

remaining_in_batch: usize

config: Config

batcher: ()

best_tip_diff_relay: Option<()>

verification_key_table: VkRefcountTable

Implementations

impl TransactionPool

pub fn new(config: Config, consensus_constants: &ConsensusConstants) -> Self

pub fn size(&self) -> usize

pub fn get_all_transactions(&self) -> Vec<ValidCommandWithHash>

pub fn get_pending_amount_and_nonce( &self, ) -> HashMap<AccountId, (Option<Nonce>, Amount)>

pub fn transactions(&mut self, limit: usize) -> Vec<ValidCommandWithHash>

pub fn list_includable_transactions( &self, limit: usize, ) -> Vec<ValidCommandWithHash>

pub fn get_accounts_to_revalidate_on_new_best_tip(&self) -> BTreeSet<AccountId>

pub fn on_new_best_tip( &mut self, global_slot_since_genesis: Slot, accounts: &BTreeMap<AccountId, Account>, ) -> Result<Vec<ValidCommandWithHash>, CommandError>

fn has_sufficient_fee(&self, pool_max_size: usize, cmd: &UserCommand) -> bool

fn drop_until_below_max_size( &mut self, pool_max_size: usize, ) -> Result<Vec<ValidCommandWithHash>, CommandError>

pub fn get_accounts_to_handle_transition_diff( &self, diff: &BestTipDiff, ) -> (BTreeSet<AccountId>, BTreeSet<AccountId>)

pub fn handle_transition_frontier_diff( &mut self, global_slot_since_genesis: Slot, current_global_slot: Slot, diff: &BestTipDiff, account_ids: &BTreeSet<AccountId>, accounts: &BTreeMap<AccountId, Account>, uncommited: &BTreeMap<AccountId, Account>, ) -> Result<(), String>

pub fn get_accounts_to_apply_diff( &self, diff: &DiffVerified, ) -> BTreeSet<AccountId>

fn apply( &mut self, time: Timestamp, global_slot_since_genesis: Slot, current_global_slot: Slot, diff: &DiffVerified, accounts: &BTreeMap<AccountId, Account>, is_sender_local: bool, ) -> Result<(ApplyDecision, Vec<ValidCommandWithHash>, Vec<(ValidCommandWithHash, Error)>, HashSet<TransactionHash>), String>

pub fn unsafe_apply( &mut self, time: Timestamp, global_slot_since_genesis: Slot, current_global_slot: Slot, diff: &DiffVerified, accounts: &BTreeMap<AccountId, Account>, is_sender_local: bool, ) -> Result<(ApplyDecision, Vec<ValidCommandWithHash>, Vec<(ValidCommandWithHash, Error)>, HashSet<TransactionHash>), String>

fn register_locally_generated( &mut self, time: Timestamp, cmd: &ValidCommandWithHash, )

pub fn prevalidate(&self, diff: Diff) -> Result<Diff, TransactionPoolErrors>

pub fn convert_diff_to_verifiable( &self, diff: Diff, accounts: &BTreeMap<AccountId, Account>, ) -> Result<Vec<WithStatus<UserCommand>>, TransactionPoolErrors>

pub fn verify_proofs( &self, diff: Vec<WithStatus<UserCommand>>, ) -> Result<Vec<UserCommand>, TransactionPoolErrors>

fn get_rebroadcastable<F>(&mut self, has_timed_out: F) -> Vec<Vec<UserCommand>>

where F: Fn(&Timestamp) -> bool,

Trait Implementations

impl Clone for TransactionPool

fn clone(&self) -> TransactionPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TransactionPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TransactionPool

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TransactionPool

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.