Struct akka_projection_rs_commitlog::CommitLogSourceProvider

pub struct CommitLogSourceProvider<CL, E, M> { /* private fields */ }

Source events for given slices from a Streambed commit log.

Implementations

impl<CL, E, M> CommitLogSourceProvider<CL, E, M>

where CL: CommitLog, M: CommitLogMarshaller<E> + Sync, for<'async_trait> E: DeserializeOwned + Serialize + Send + Sync + 'async_trait,

pub fn new( commit_log: CL, marshaller: M, consumer_group_name: &str, topic: Topic ) -> Self

pub fn with_slice_range( commit_log: CL, marshaller: M, consumer_group_name: &str, topic: Topic, slice_range: Range<u32> ) -> Self

Trait Implementations

impl<CL, E, M> SourceProvider for CommitLogSourceProvider<CL, E, M>

where CL: CommitLog, M: CommitLogMarshaller<E> + Send + Sync, for<'async_trait> E: DeserializeOwned + Serialize + Send + Sync + 'async_trait,

type Envelope = EventEnvelope<E>

The envelope processed by the provider.

fn source<'life0, 'async_trait, F, FR>( &'life0 self, offset: F ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Self::Envelope> + Send + 'async_trait>>> + Send + 'async_trait>>

where F: Fn() -> FR + Send + Sync + 'async_trait, FR: Future<Output = Option<LastOffset>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Given a closure that returns an offset, source envelopes.

fn load_envelope<'life0, 'async_trait>( &'life0 self, _persistence_id: PersistenceId, _sequence_nr: u64 ) -> Pin<Box<dyn Future<Output = Option<Self::Envelope>> + Send + 'async_trait>>

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

Load a single event on demand. A None is returned if the event for the given persistence_id and seq_nr doesn’t exist.