Module refresh_manager 

Structs

CycleTracker 🔒

Cycles 🔒

GlobalRefreshManager

Owns the refresh cycles. The refresh_job row is the source of truth: a cycle is its last_trigger_time, and both transitions are the post-collect of a barrier (RefreshStart moves the job to Refreshing, FinishRefresh back to Idle). A recovery kills every cycle of the databases it re-initializes and moves their rows back to Idle before those databases accept commands again (abandon_cycles), so nothing has to infer an abandoned cycle afterwards. The in-memory tracker of a cycle is installed by the same barrier that started it, before the row moves.

RefreshCycleActors

The actors of a refreshable table’s job, grouped by the stage they report.

RefreshFinishedMetrics 🔒

RefreshJobMetrics 🔒

StageProgress 🔒

Enums

RefreshStage

RetryState 🔒

An abandoned cycle is re-run once; the state is cleared by a successful cycle.

TriggerReason 🔒

Functions

cron_due 🔒

created_at_millis stands in for the last trigger time of a job that never ran.

cron_interval 🔒

cycle_duration_secs 🔒

Wall-clock length of a cycle; falls back to the trigger time when the tracker did not survive a meta restart.

millis_to_datetime 🔒

now_millis 🔒

Truncated to the millisecond precision of the persisted trigger time.

Type Aliases

GlobalRefreshManagerRef