Struct PluginPollerProxy 

pub struct PluginPollerProxy { /* private fields */ }

Daemon-side Poller impl that proxies every tick to a subprocess plugin via broker JSON-RPC. Registered with the runner alongside in-tree builtins so the runner sees a single homogeneous registry.

kind() returns the leaked &'static str for one of the plugin’s declared kinds; multi-kind plugins register one proxy per kind sharing the same PluginPollerHandle.

Implementations

impl PluginPollerProxy

pub fn new( kind: &'static str, handle: Arc<PluginPollerHandle>, broker: AnyBroker, ) -> Self

Wrap a (handle, kind) pair into a Poller impl. kind must be one of handle.kinds; the runner validates this at boot.

Trait Implementations

impl Poller for PluginPollerProxy

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

Discriminator used in YAML (kind: rss) and metrics.

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

Human label for agent pollers list. Defaults to empty.

fn tick<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 PollContext, ) -> Pin<Box<dyn Future<Output = Result<TickAck, PollerError>> + Send + 'async_trait>>

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

Run one tick. The runner persists the returned cursor and honors the interval hint; anything the poller wants to send outbound (broker publish, LLM call, credential lookup) goes through ctx.host.

fn validate(&self, _config: &Value) -> Result<(), PollerError>

Validate the per-job config JSON at boot. Errors fail loading of that job only; siblings keep going. Default: accept anything.

fn custom_tools(&self) -> Vec<CustomToolSpec>

Optional per-kind LLM tools registered alongside the generic pollers_* tools. Pollers without custom tools leave this empty (default).