Struct MirrorModule 

pub struct MirrorModule { /* private fields */ }

Mirror module wrapping a Syncer.

Implementations

impl MirrorModule

pub fn new(syncer: Syncer) -> Self

Build a module with the default id.

pub fn with_id(id: impl Into<String>, syncer: Syncer) -> Self

Build a module with a custom id.

pub fn syncer(&self) -> Arc<Mutex<Syncer>>

Access the wrapped syncer for direct calls (e.g. register_source).

Trait Implementations

impl Module for MirrorModule

fn metadata(&self) -> ModuleMetadata

Static module metadata.

fn init<'life0, 'async_trait>( &'life0 mut self, bus: MessageBus, ) -> Pin<Box<dyn Future<Output = KernelResult<()>> + Send + 'async_trait>>

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

Initialize the module. Called once, before start.

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

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

Start the module. Must be idempotent.

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

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

Stop the module. Must be idempotent and quick; long-running cleanup belongs in a separate task signalled from here.