Struct RecurringJobPoller 

pub struct RecurringJobPoller { /* private fields */ }

Background poller that materializes due [RecurringJob] templates.

Implementations

impl RecurringJobPoller

pub fn new(storage: Arc<dyn Storage>, poll_interval: Duration) -> Self

pub async fn run_until_cancelled(&self, cancel: CancellationToken) -> Result<()>

Run the poll loop until cancel fires.

pub async fn tick_once(&self) -> Result<usize>

One poll iteration — claim due templates, enqueue a Job for each, advance next_run_at, and upsert. Exposed for tests.