Trait Worker 

pub trait Worker:
    MaybeSend
    + MaybeSync
    + 'static {
    // Required methods
    fn kind(&self) -> WorkerKind;
    fn run_tasks<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn NeedsDbReconnect>>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;

    // Provided methods
    fn set_subscription(
        &mut self,
        _subscription: Arc<Subscription<InternalEvent>>,
    ) { ... }
    fn sync_metrics(&self) -> Option<Arc<WorkerMetrics<SyncMetric>>> { ... }
    fn boxed(self) -> Box<dyn Worker>
       where Self: Sized { ... }
    fn spawn(
        self: Box<Self>,
        cancel: CancellationToken,
    ) -> Instrumented<Pin<Box<dyn Future<Output = WorkerKind> + Send>>> { ... }
}

Required Methods

fn kind(&self) -> WorkerKind

fn run_tasks<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn NeedsDbReconnect>>> + Send + 'async_trait>>

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

Provided Methods

fn set_subscription(&mut self, _subscription: Arc<Subscription<InternalEvent>>)

fn sync_metrics(&self) -> Option<Arc<WorkerMetrics<SyncMetric>>>

The metrics of the device-sync worker; no other worker has any.

fn boxed(self) -> Box<dyn Worker>

where Self: Sized,

Box the worker, erasing its type

fn spawn( self: Box<Self>, cancel: CancellationToken, ) -> Instrumented<Pin<Box<dyn Future<Output = WorkerKind> + Send>>>

Implementors

impl<Context> Worker for ConfigurationWorker<Context>

where Context: CoreContext + 'static,

impl<Context> Worker for HmacEpochWorker<Context>

where Context: CoreContext + 'static,

impl<Context> Worker for CommitLogWorker<Context>

where Context: XmtpSharedContext + 'static,

impl<Context> Worker for SyncWorker<Context>

where Context: XmtpSharedContext + 'static,

impl<Context> Worker for DisappearingMessagesWorker<Context>

where Context: CoreContext + 'static,

impl<Context, Handlers> Worker for TaskWorker<Context, Handlers>

where Context: CoreContext + 'static, Handlers: TaskHandlers<Context> + 'static,