Trait eventify_idx::types::process::Process

pub trait Process<T> {
    type Error;

    // Required methods
    fn process<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn stream_latest<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

The Process trait defines asynchronous operations for processing different types of data. It’s generic over a type T, allowing flexibility in the type of data being processed.

This trait is ideal for scenarios where data needs to be processed, streamed, or monitored in real-time.

Required Associated Types

type Error

Required Methods

fn process<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Asynchronously processes data of type T.

This method should contain the core logic for processing the data. The specifics of what processing entails (e.g., fetching, parsing, storing) are determined by the implementing type.

fn stream<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Asynchronously streams data of type T.

This method should provide the functionality to continuously stream data. The nature of the streaming (e.g., real-time, batch processing) depends on the implementing type.

fn stream_latest<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Asynchronously streams the latest available data of type T.

This method should specifically focus on streaming the most recent data. It’s useful in scenarios where the latest information is critical, such as real-time monitoring or alerting systems.

Implementors

impl<T, U> Process<IndexedBlock> for Collector<T, U>

where T: JsonRpcClient + Clone + 'static, U: Storage + Auth + Clone + 'static,

type Error = Error

impl<T, U> Process<IndexedLog> for Collector<T, U>

where T: JsonRpcClient + Clone + 'static, U: Storage + Auth + Clone + 'static,

type Error = Error