Trait engula_kernel::Stream[−][src]

pub trait Stream: 'static + Clone + Send + Sync {
    fn read_events<'life0, 'async_trait>(
        &'life0 self, 
        ts: Timestamp
    ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Result<Vec<Event, Global>, Error>> + Send + 'static, Global>>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn append_event<'life0, 'async_trait>(
        &'life0 self, 
        event: Event
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn release_events<'life0, 'async_trait>(
        &'life0 self, 
        ts: Timestamp
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}
Expand description

An interface to manipulate a stream.

Required methods

Reads events since a timestamp (inclusive).

Appends an event.

Releases events up to a timestamp (exclusive).

Implementations on Foreign Types

Implementors