Trait tc_service::TransactionPool[−][src]

pub trait TransactionPool: Send + Sync {
    type Block: Block;
    type Hash: Hash + Eq + Member + Serialize;
    type InPoolTransaction: InPoolTransaction;
    type Error: From<Error> + IntoPoolError;
    pub fn submit_at(
        &self, 
        at: &BlockId<Self::Block>, 
        source: TransactionSource, 
        xts: Vec<<Self::Block as Block>::Extrinsic, Global>
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Result<Self::Hash, Self::Error>, Global>, Self::Error>> + 'static + Send, Global>>;

    pub fn submit_one(
        &self, 
        at: &BlockId<Self::Block>, 
        source: TransactionSource, 
        xt: <Self::Block as Block>::Extrinsic
    ) -> Pin<Box<dyn Future<Output = Result<Self::Hash, Self::Error>> + 'static + Send, Global>>;

    pub fn submit_and_watch(
        &self, 
        at: &BlockId<Self::Block>, 
        source: TransactionSource, 
        xt: <Self::Block as Block>::Extrinsic
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = TransactionStatus<Self::Hash, <Self::Block as Block>::Hash>> + 'static + Send + Unpin, Global>, Self::Error>> + 'static + Send, Global>>;

    pub fn ready_at(
        &self, 
        at: <<Self::Block as Block>::Header as Header>::Number
    ) -> Pin<Box<dyn Future<Output = Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + 'static + Send, Global>> + 'static + Send, Global>>;

    pub fn ready(
        &self
    ) -> Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + 'static + Send, Global>;

    pub fn remove_invalid(
        &self, 
        hashes: &[Self::Hash]
    ) -> Vec<Arc<Self::InPoolTransaction>, Global>;

    pub fn status(&self) -> PoolStatus;

    pub fn import_notification_stream(&self) -> Receiver<Self::Hash>;

    pub fn on_broadcasted(
        &self, 
        propagations: HashMap<Self::Hash, Vec<String, Global>, RandomState>
    );

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

    pub fn ready_transaction(
        &self, 
        hash: &Self::Hash
    ) -> Option<Arc<Self::InPoolTransaction>>;
}

Transaction pool interface.

Associated Types

type Block: Block[src]

Block type.

type Hash: Hash + Eq + Member + Serialize[src]

Transaction hash type.

type InPoolTransaction: InPoolTransaction[src]

In-pool transaction type.

type Error: From<Error> + IntoPoolError[src]

Error type.

Loading content...

Required methods

pub fn submit_at(
    &self,
    at: &BlockId<Self::Block>,
    source: TransactionSource,
    xts: Vec<<Self::Block as Block>::Extrinsic, Global>
) -> Pin<Box<dyn Future<Output = Result<Vec<Result<Self::Hash, Self::Error>, Global>, Self::Error>> + 'static + Send, Global>>[src]

Returns a future that imports a bunch of unverified transactions to the pool.

pub fn submit_one(
    &self,
    at: &BlockId<Self::Block>,
    source: TransactionSource,
    xt: <Self::Block as Block>::Extrinsic
) -> Pin<Box<dyn Future<Output = Result<Self::Hash, Self::Error>> + 'static + Send, Global>>[src]

Returns a future that imports one unverified transaction to the pool.

pub fn submit_and_watch(
    &self,
    at: &BlockId<Self::Block>,
    source: TransactionSource,
    xt: <Self::Block as Block>::Extrinsic
) -> Pin<Box<dyn Future<Output = Result<Box<dyn Stream<Item = TransactionStatus<Self::Hash, <Self::Block as Block>::Hash>> + 'static + Send + Unpin, Global>, Self::Error>> + 'static + Send, Global>>[src]

Returns a future that import a single transaction and starts to watch their progress in the pool.

pub fn ready_at(
    &self,
    at: <<Self::Block as Block>::Header as Header>::Number
) -> Pin<Box<dyn Future<Output = Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + 'static + Send, Global>> + 'static + Send, Global>>[src]

Get an iterator for ready transactions ordered by priority.

Guarantees to return only when transaction pool got updated at at block. Guarantees to return immediately when None is passed.

pub fn ready(
    &self
) -> Box<dyn Iterator<Item = Arc<Self::InPoolTransaction>> + 'static + Send, Global>[src]

Get an iterator for ready transactions ordered by priority.

pub fn remove_invalid(
    &self,
    hashes: &[Self::Hash]
) -> Vec<Arc<Self::InPoolTransaction>, Global>[src]

Remove transactions identified by given hashes (and dependent transactions) from the pool.

pub fn status(&self) -> PoolStatus[src]

Returns pool status.

pub fn import_notification_stream(&self) -> Receiver<Self::Hash>[src]

Return an event stream of transactions imported to the pool.

pub fn on_broadcasted(
    &self,
    propagations: HashMap<Self::Hash, Vec<String, Global>, RandomState>
)[src]

Notify the pool about transactions broadcast.

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

Returns transaction hash

pub fn ready_transaction(
    &self,
    hash: &Self::Hash
) -> Option<Arc<Self::InPoolTransaction>>[src]

Return specific ready transaction by hash, if there is one.

Loading content...

Implementations on Foreign Types

impl<PoolApi, Block> TransactionPool for BasicPool<PoolApi, Block> where
    Block: Block,
    PoolApi: 'static + ChainApi<Block = Block>, [src]

type Block = <PoolApi as ChainApi>::Block

type Hash = <<PoolApi as ChainApi>::Block as Block>::Hash

type InPoolTransaction = Transaction<<BasicPool<PoolApi, Block> as TransactionPool>::Hash, <<BasicPool<PoolApi, Block> as TransactionPool>::Block as Block>::Extrinsic>

type Error = <PoolApi as ChainApi>::Error

Loading content...

Implementors

Loading content...