Struct AccountPipe

pub struct AccountPipe<T: Send> {
    pub decoder: Box<dyn for<'a> AccountDecoder<'a, AccountType = T> + Send + Sync + 'static>,
    pub processor: Box<dyn Processor<InputType = AccountProcessorInputType<T>> + Send + Sync>,
    pub filters: Vec<Box<dyn Filter + Send + Sync + 'static>>,
}

A processing pipe that decodes and processes Solana account updates.

AccountPipe combines an AccountDecoder and a Processor to manage account updates in the pipeline. This struct decodes the raw account data and then processes the resulting DecodedAccount with the specified processing logic.

Type Parameters

• T: The data type of the decoded account information, as determined by the decoder.

Fields

• decoder: An AccountDecoder that decodes raw account data into structured form.
• processor: A Processor that handles the processing logic for decoded accounts.
• filters: A collection of filters that determine which account updates should be processed. Each filter in this collection is applied to incoming account updates, and only updates that pass all filters (return true) will be processed. If this collection is empty, all updates are processed.

Fields

decoder: Box<dyn for<'a> AccountDecoder<'a, AccountType = T> + Send + Sync + 'static>

processor: Box<dyn Processor<InputType = AccountProcessorInputType<T>> + Send + Sync>

filters: Vec<Box<dyn Filter + Send + Sync + 'static>>

Trait Implementations

impl<T: Send> AccountPipes for AccountPipe<T>

fn run<'life0, 'async_trait>( &'life0 mut self, account_with_metadata: (AccountMetadata, Account), metrics: Arc<MetricsCollection>, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn filters(&self) -> &Vec<Box<dyn Filter + Send + Sync + 'static>>