Struct PluginPollerRouter 

pub struct PluginPollerRouter { /* private fields */ }

Daemon-side router. Looks up which plugin owns a kind and forwards tick requests via broker JSON-RPC.

Implementations

impl PluginPollerRouter

pub fn new() -> Self

pub fn register( &self, handle: PluginPollerHandle, ) -> Result<(), PollerRouteRegistrationError>

Register a plugin’s poller capability. Returns an error if any of the requested kinds is already owned by a different plugin (cross-manifest uniqueness — boot-time fail-fast). Re-registration of the same plugin_id is allowed and replaces the previous entry (hot-spawn restart).

pub fn unregister(&self, plugin_id: &str) -> bool

Drop the handle for a given plugin id (hot-remove).

pub fn handle_for_kind(&self, kind: &str) -> Option<Arc<PluginPollerHandle>>

Look up the handle that owns kind. Returns an Arc clone so the caller can drop the read lock immediately.

pub fn handles_for_plugin( &self, plugin_id: &str, ) -> Option<Arc<PluginPollerHandle>>

Look up the handle owned by plugin_id. Used by the daemon boot loop to wire one PluginPollerProxy per declared kind.

pub fn is_empty(&self) -> bool

True when no plugins are registered. Used by the runner’s fast-path skip.

pub fn len(&self) -> usize

Number of registered plugins. For metrics.

Trait Implementations

impl Debug for PluginPollerRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PluginPollerRouter

fn default() -> PluginPollerRouter

Returns the “default value” for a type.