Struct EngineStatePoller 

pub struct EngineStatePoller { /* private fields */ }

Handle to a running HTTP-backfill poller for the core mirror fields.

Same lifecycle semantics as OperatorStatePoller: dropping the handle does not stop the task; call EngineStatePoller::shutdown for a clean exit.

Implementations

impl EngineStatePoller

pub fn spawn(http: HttpClient, state: Arc<RwLock<EngineState>>) -> Self

Spawn a backfill poller for status / positions / risk / regime / live_cockpit. Returns immediately — the first poll happens in the background task on the first tick.

pub fn spawn_with_interval( http: HttpClient, state: Arc<RwLock<EngineState>>, interval: Duration, ) -> Self

Like Self::spawn with a custom interval. Used by tests to exercise multiple polls in a short wall-clock window.

pub async fn shutdown(self) -> Result<(), JoinError>

Signal the task to exit and wait for it.

Errors

Returns the tokio join error verbatim on panic or cancel; clean shutdown always returns Ok.

Trait Implementations

impl Debug for EngineStatePoller

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

Formats the value using the given formatter.