Struct TransactionValidationTaskExecutor

pub struct TransactionValidationTaskExecutor<V> {
    pub validator: V,
    pub to_validation_task: Arc<Mutex<ValidationJobSender>>,
}

A spawnable task that performs transaction validation. A TransactionValidator implementation that validates ethereum transaction.

This validator is non-blocking, all validation work is done in a separate task.

Fields

validator: V

The validator that will validate transactions on a separate task.

to_validation_task: Arc<Mutex<ValidationJobSender>>

The sender half to validation tasks that perform the actual validation.

Implementations

impl TransactionValidationTaskExecutor<()>

pub fn eth_builder(chain_spec: Arc<ChainSpec>) -> EthTransactionValidatorBuilder

Convenience method to create a EthTransactionValidatorBuilder

impl<V> TransactionValidationTaskExecutor<V>

pub fn map<F, T>(self, f: F) -> TransactionValidationTaskExecutor<T>

where F: FnMut(V) -> T,

Maps the given validator to a new type.

impl<Client, Tx> TransactionValidationTaskExecutor<EthTransactionValidator<Client, Tx>>

pub fn eth<T, S: BlobStore>( client: Client, chain_spec: Arc<ChainSpec>, blob_store: S, tasks: T, ) -> Self

where T: TaskSpawner,

Creates a new instance for the given [ChainSpec]

This will spawn a single validation tasks that performs the actual validation. See TransactionValidationTaskExecutor::eth_with_additional_tasks

pub fn eth_with_additional_tasks<T, S: BlobStore>( client: Client, chain_spec: Arc<ChainSpec>, blob_store: S, tasks: T, num_additional_tasks: usize, ) -> Self

where T: TaskSpawner,

Creates a new instance for the given [ChainSpec]

By default this will enable support for:

• shanghai
• eip1559
• eip2930

This will always spawn a validation task that performs the actual validation. It will spawn num_additional_tasks additional tasks.

impl<V> TransactionValidationTaskExecutor<V>

pub fn new(validator: V) -> Self

Creates a new executor instance with the given validator for transaction validation.

Initializes the executor with the provided validator and sets up communication for validation tasks.

Trait Implementations

impl<V: Clone> Clone for TransactionValidationTaskExecutor<V>

fn clone(&self) -> TransactionValidationTaskExecutor<V>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<V: Debug> Debug for TransactionValidationTaskExecutor<V>

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

Formats the value using the given formatter.

impl<V> TransactionValidator for TransactionValidationTaskExecutor<V>

where V: TransactionValidator + Clone + 'static,

type Transaction = <V as TransactionValidator>::Transaction

The transaction type to validate.

async fn validate_transaction( &self, origin: TransactionOrigin, transaction: Self::Transaction, ) -> TransactionValidationOutcome<Self::Transaction>

Validates the transaction and returns a TransactionValidationOutcome describing the validity of the given transaction.

fn on_new_head_block<H, B>(&self, new_tip_block: &SealedBlock<H, B>)

where H: BlockHeader, B: BlockBody,

Invoked when the head block changes.

fn validate_transactions( &self, transactions: Vec<(TransactionOrigin, Self::Transaction)>, ) -> impl Future<Output = Vec<TransactionValidationOutcome<Self::Transaction>>> + Send

Validates a batch of transactions.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.