Struct sc_transaction_pool::Pool

impl<B: ChainApi> Pool

pub fn new(options: Options, is_validator: IsValidator, api: Arc) -> Self

Create a new transaction pool.

pub async fn submit_at( &self, at: &BlockId<B::Block>, source: TransactionSource, xts: impl IntoIterator<Item = <::Block as Block>::Extrinsic> ) -> Result<Vec<Result<<::Block as Block>::Hash, B::Error>>, B::Error>

Imports a bunch of unverified extrinsics to the pool

pub async fn resubmit_at( &self, at: &BlockId<B::Block>, source: TransactionSource, xts: impl IntoIterator<Item = <::Block as Block>::Extrinsic> ) -> Result<Vec<Result<<::Block as Block>::Hash, B::Error>>, B::Error>

Resubmit the given extrinsics to the pool.

This does not check if a transaction is banned, before we verify it again.

pub async fn submit_one( &self, at: &BlockId<B::Block>, source: TransactionSource, xt: <::Block as Block>::Extrinsic ) -> Result<<::Block as Block>::Hash, B::Error>

Imports one unverified extrinsic to the pool

pub async fn submit_and_watch( &self, at: &BlockId<B::Block>, source: TransactionSource, xt: <::Block as Block>::Extrinsic ) -> Result<Watcher<<::Block as Block>::Hash, <::Block as Block>::Hash>, B::Error>

Import a single extrinsic and starts to watch its progress in the pool.

pub fn resubmit( &self, revalidated_transactions: HashMap<<::Block as Block>::Hash, ValidatedTransaction<<::Block as Block>::Hash, <::Block as Block>::Extrinsic, ::Error>> )

Resubmit some transaction that were validated elsewhere.

pub fn prune_known( &self, at: &BlockId<B::Block>, hashes: &[<::Block as Block>::Hash] ) -> Result<(), B::Error>

Prunes known ready transactions.

Used to clear the pool from transactions that were part of recently imported block. The main difference from the prune is that we do not revalidate any transactions and ignore unknown passed hashes.

pub async fn prune( &self, at: &BlockId<B::Block>, parent: &BlockId<B::Block>, extrinsics: &[<::Block as Block>::Extrinsic] ) -> Result<(), B::Error>

Prunes ready transactions.

Used to clear the pool from transactions that were part of recently imported block. To perform pruning we need the tags that each extrinsic provides and to avoid calling into runtime too often we first lookup all extrinsics that are in the pool and get their provided tags from there. Otherwise we query the runtime at the parent block.

pub async fn prune_tags( &self, at: &BlockId<B::Block>, tags: impl IntoIterator<Item = Tag>, known_imported_hashes: impl IntoIterator<Item = <::Block as Block>::Hash> + Clone ) -> Result<(), B::Error>

Prunes ready transactions that provide given list of tags.

Given tags are assumed to be always provided now, so all transactions in the Future Queue that require that particular tag (and have other requirements satisfied) are promoted to Ready Queue.

Moreover for each provided tag we remove transactions in the pool that:

Provide that tag directly
Are a dependency of pruned transaction.

Returns transactions that have been removed from the pool and must be reverified before reinserting to the pool.

By removing predecessor transactions as well we might actually end up pruning too much, so all removed transactions are reverified against the runtime (validate_transaction) to make sure they are invalid.

However we avoid revalidating transactions that are contained within the second parameter of known_imported_hashes. These transactions (if pruned) are not revalidated and become temporarily banned to prevent importing them in the (near) future.

pub fn hash_of( &self, xt: &<::Block as Block>::Extrinsic ) -> <::Block as Block>::Hash

Returns transaction hash

pub fn validated_pool(&self) -> &ValidatedPool

get a reference to the underlying validated pool.

Trait Implementations§

impl<B: ChainApi> Clone for Pool

fn clone(&self) -> Self

Returns a copy of the value. Read more

1.0.0 · source§

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

Performs copy-assignment from source. Read more

Auto Trait Implementations§

impl !UnwindSafe for Pool

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for Twhere T: ?Sized,

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for Twhere T: ?Sized,

const: unstable · source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> CheckedConversion for T

fn checked_from<T>(t: T) -> Option<Self>where Self: TryFrom<T>,

Convert from a value of T into an equivalent instance of Option<Self>. Read more

fn checked_into<T>(self) -> Option<T>where Self: TryInto<T>,

Consume self to return Some equivalent value of Option<T>. Read more

impl<T> Downcast for Twhere T: Any,

fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Send + Sync + 'static>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.