Struct MessagingPlugin 

pub struct MessagingPlugin { /* private fields */ }

Daemon plugin shell.

The daemon constructs the MessagingService first (since its RPC layer needs a direct handle to call send, mark_*, history, etc.) and then wraps it with this plugin so payload dispatch and lifecycle hooks can flow through the same instance.

Implementations

impl MessagingPlugin

pub fn new(service: Arc<MessagingService>) -> Arc<Self>

Wrap an existing MessagingService as a DaemonPlugin.

Trait Implementations

impl DaemonPlugin for MessagingPlugin

fn name(&self) -> &'static str

Stable identifier — used for log spans and (by convention) as a prefix for the plugin’s payload kinds.

fn payload_kinds(&self) -> &'static [&'static str]

Stable list of PluginPayload.kind values this plugin claims. The daemon dispatches inbound payloads by matching kind against each registered plugin in order; the first match wins.

fn handle_payload<'life0, 'life1, 'async_trait>( &'life0 self, src: NodeId, kind: &'life1 str, body: Bytes, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle an inbound ControlFrame::PluginPayload whose kind appeared in Self::payload_kinds.

fn start<'async_trait>( self: Arc<Self>, _ctx: PluginContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait,

Spawn whatever long-running tasks the plugin needs. Returns once startup is complete; long-running work should be on detached tokio::spawn handles tied to ctx.cancel.

fn on_peer_forgotten<'life0, 'async_trait>( &'life0 self, peer: NodeId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Notification: the daemon dropped this peer’s identity from the keystore (e.g. via peers.forget). Plugins typically wipe any per-peer state of their own here. Failure is logged but does not block other plugins from being notified.

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

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

Best-effort shutdown — called once at daemon teardown.