Struct ScheduleTicker 

pub struct ScheduleTicker { /* private fields */ }

Periodic task that fires DB-persisted schedules.

Examples

use std::sync::Arc;
use std::time::Duration;
use ironflow_api::schedule_ticker::ScheduleTicker;
use ironflow_api::schedule_sync::sync_handler_schedules;
use ironflow_engine::engine::Engine;
use ironflow_core::providers::claude::ClaudeCodeProvider;
use ironflow_store::memory::InMemoryStore;
use ironflow_store::store::Store;
use tokio_util::sync::CancellationToken;

let store: Arc<dyn Store> = Arc::new(InMemoryStore::new());
let engine = Engine::new(store.clone(), Arc::new(ClaudeCodeProvider::new()));
sync_handler_schedules(&engine, store.as_ref()).await?;

let ticker = ScheduleTicker::new(store).interval(Duration::from_secs(10));
tokio::spawn(ticker.run(CancellationToken::new()));

Implementations

impl ScheduleTicker

pub fn new(store: Arc<dyn Store>) -> Self

Create a ticker with the default interval.

pub fn interval(self, interval: Duration) -> Self

Set how often due schedules are polled.

pub async fn run(self, shutdown: CancellationToken)

Run the tick loop until shutdown is cancelled.

Store errors are logged per-schedule; the loop keeps going.

pub async fn tick(&self)

Process one batch of due schedules.

Exposed for tests and for callers that drive the tick themselves.