Struct Poller 

pub struct Poller {
    config: RwLock<PollerConfig>,
    _handler: &'static ReactiveHandler,
    running: Mutex<bool>,
    poll_count: Mutex<u64>,
    injections_count: Mutex<u64>,
    last_poll: Mutex<Option<u64>>,
    last_error: Mutex<Option<String>>,
}

Poller state for cross-host message polling from AgentMux.

Fields

config: RwLock<PollerConfig>

_handler: &'static ReactiveHandler

running: Mutex<bool>

poll_count: Mutex<u64>

injections_count: Mutex<u64>

last_poll: Mutex<Option<u64>>

last_error: Mutex<Option<String>>

Implementations

impl Poller

pub fn new(config: PollerConfig, handler: &'static ReactiveHandler) -> Self

Create a new poller with the given config.

pub fn is_configured(&self) -> bool

Check if the poller is configured (has URL and token).

pub fn is_running(&self) -> bool

Check if the poller is running.

pub fn stats(&self) -> HashMap<String, Value>

Get poller statistics.

pub fn status(&self) -> PollerStatus

Get poller status.

pub fn reconfigure(&self, url: Option<String>, token: Option<String>)

Reconfigure the poller with new URL and token.

pub fn record_poll(&self)

Record a successful poll.

pub fn record_error(&self, err: &str)

Record a poll error.

pub fn record_injections(&self, count: u64)

Record injections delivered.

pub fn set_running(&self, running: bool)

Set the running state.