Struct OutboxBuilder 

pub struct OutboxBuilder<E> { /* private fields */ }

Implementations

impl<E: Clone + Send + 'static> OutboxBuilder<E>

pub fn name(self, n: impl Into<String>) -> Self

pub fn read_journal<R: ReadJournal>(self, rj: Arc<R>) -> Self

pub fn poll_interval(self, d: Duration) -> Self

pub fn decode<F>(self, f: F) -> Self

where F: Fn(&[u8]) -> Result<E, String> + Send + Sync + 'static,

pub fn publish<F, Fut>(self, f: F) -> Self

where F: Fn(E) -> Fut + Send + Sync + 'static, Fut: Future<Output = bool> + Send + 'static,

pub fn offset_store<S: OutboxOffsetStore>(self, s: Arc<S>) -> Self

pub fn build(self) -> Result<OutboxTopology<E>, PatternError<()>>