Struct CandlePollerService 

pub struct CandlePollerService { /* private fields */ }

Periodic poll of a CandleSource for a single (symbol, interval) pair. Publishes each newly-closed candle to the MarketDataBus.

Per-symbol cadences are achieved by spawning multiple services — Bot::with_candle_poller(...) accepts repeated calls and spawns one service per registered tuple.

Deduplication

The service tracks the highest Candle::time it has already published; only candles with a strictly greater timestamp are re-published. This is robust against exchanges that return overlapping windows on consecutive polls.

Implementations

impl CandlePollerService

pub fn polled(&self) -> u64

Total successful polls.

pub fn poll_errors(&self) -> u64

Total failed polls.

pub fn published(&self) -> u64

Total candles published (deduplicated).

Trait Implementations

impl TradingService for CandlePollerService

fn name(&self) -> &str

Unique service name for logs, metrics, and supervisor identification.

fn restart_policy(&self) -> RestartPolicy

When should the supervisor restart this service on exit?

fn run<'life0, 'async_trait>( &'life0 self, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Main execution loop. Must honour the cancellation token.