Struct DefaultOutboxRelay 

pub struct DefaultOutboxRelay<UowFactory, O, F, W, T>
where
    UowFactory: UnitOfWorkFactory,
    O: Outbox,
    F: OutboxFetcher<Uow = UowFactory::Uow, Outbox = O>,
    W: OutboxWriter<Uow = UowFactory::Uow, Outbox = O>,
    T: Topic<O::Message> + Sync,
{ /* private fields */ }

Implementations

impl<UowFactory, O, F, W, T> DefaultOutboxRelay<UowFactory, O, F, W, T>

where UowFactory: UnitOfWorkFactory, O: Outbox, F: OutboxFetcher<Uow = UowFactory::Uow, Outbox = O>, W: OutboxWriter<Uow = UowFactory::Uow, Outbox = O>, T: Topic<O::Message> + Sync,

pub fn new( config: OutboxRelayConfig, topic: T, fetcher: F, writer: W, uow_factory: UowFactory, ) -> Self

Trait Implementations

impl<UowFactory, O, F, W, T> OutboxRelay for DefaultOutboxRelay<UowFactory, O, F, W, T>

where UowFactory: UnitOfWorkFactory, O: Outbox, F: OutboxFetcher<Uow = UowFactory::Uow, Outbox = O>, W: OutboxWriter<Uow = UowFactory::Uow, Outbox = O>, T: Topic<O::Message> + Sync,

type Outbox = O

fn is_stop_requested(&self) -> bool

fn request_graceful_stop(&mut self)

async fn run_forever(&self) -> Result<(), OutboxRelayError>

async fn run_once(&self) -> Result<OutboxRelayRunReport, OutboxRelayError>