Struct CronSource 

pub struct CronSource { /* private fields */ }

Event source that emits events on a fixed interval

Uses tokio::time::interval for scheduling and Notify for graceful shutdown.

Implementations

impl CronSource

pub fn new<F>(name: impl Into<String>, interval: Duration, factory: F) -> Self

where F: Fn() -> Event + Send + Sync + 'static,

Create a new cron source

• name — source identifier
• interval — time between event emissions
• factory — closure that creates each event

Trait Implementations

impl EventSource for CronSource

fn start<'life0, 'async_trait>( &'life0 self, sender: Sender<Event>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Start the source, emitting events through the sender

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

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

Signal the source to stop

fn name(&self) -> &str

Human-readable source name