Cron Scheduler

The Event Plane includes a distributed cron scheduler. Jobs are evaluated per-second and dispatched through the Control Plane → Data Plane path.

CREATE SCHEDULE nightly_cleanup
CRON '0 2 * * *'
AS BEGIN
    DELETE FROM sessions WHERE expires_at < now();
    INSERT INTO maintenance_log { task: 'nightly_cleanup', ran_at: now() };
END;

CREATE SCHEDULE refresh_stats
CRON '*/5 * * * *'
AS BEGIN
    REFRESH CONTINUOUS AGGREGATE order_stats;
END;

DROP SCHEDULE nightly_cleanup;
SHOW SCHEDULES;

Cron Syntax

Standard 5-field cron: minute hour day-of-month month day-of-week.

Leader-Aware

In clustered mode, scheduled jobs run on the collection's shard leader. If a leader changes due to failover, the new leader picks up the schedule. Job history and missed execution policies are tracked in redb.

LISTEN/NOTIFY

PostgreSQL-compatible ephemeral notifications (session-scoped, cluster-wide):

LISTEN order_events;
NOTIFY order_events, 'order 123 shipped';

For durable delivery, use Change Streams or Durable Topics.