Struct TransactionPipe 

pub struct TransactionPipe<T: InstructionDecoderCollection, U> { /* private fields */ }

A pipe for processing transactions based on a defined schema and processor.

The TransactionPipe parses a transaction’s instructions, optionally checks them against the schema, and runs the processor if the instructions match the schema. It provides methods for parsing nested instructions and matching transaction data to the schema.

Generics

• T: The instruction type, implementing InstructionDecoderCollection.
• U: The output type for the matched data, if schema-matching, implementing DeserializeOwned.

Fields

• schema: The schema against which to match transaction instructions.
• processor: The processor that will handle matched transaction data.
• filters: A collection of filters that determine which transaction updates should be processed. Each filter in this collection is applied to incoming transaction updates, and only updates that pass all filters (return true) will be processed. If this collection is empty, all updates are processed.

Implementations

impl<T: InstructionDecoderCollection, U> TransactionPipe<T, U>

pub fn new( schema: Option<TransactionSchema<T>>, processor: impl Processor<InputType = TransactionProcessorInputType<T, U>> + Send + Sync + 'static, filters: Vec<Box<dyn Filter + Send + Sync + 'static>>, ) -> Self

Creates a new TransactionPipe with the specified schema and processor.

Parameters

• schema: The schema against which to match transaction instructions.
• processor: The processor that will handle matched transaction data.
• filters: A collection of filters for selective processing of transaction updates. Filters can be used to selectively process transactions based on criteria such as datasource ID, transaction type, or other custom logic.

Returns

A TransactionPipe instance configured with the specified schema and processor.

Trait Implementations

impl<T, U> TransactionPipes<'_> for TransactionPipe<T, U>

where T: InstructionDecoderCollection + Sync + 'static, U: DeserializeOwned + Send + Sync + 'static,

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, transaction_metadata: Arc<TransactionMetadata>, instructions: &'life1 [NestedInstruction], metrics: Arc<MetricsCollection>, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

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

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