Skip to main content

Module scheduled_task

Module scheduled_task 

Source
Expand description

Database-backed scheduled task catalog and claim store.

Scheduled task rows persist product runtime schedules across process restarts and coordinate due-work claims across service instances. aster_forge_tasks owns the public scheduling DTOs and runner trait; this module only supplies the SeaORM table contract and store implementation. Product crates still own task names, intervals, execution bodies, and outcome records.

Structs§

ActiveModel
Generated by sea-orm-macros
ColumnIter
An iterator over the variants of Column
Entity
Generated by sea-orm-macros
Model
SeaORM model for scheduled_tasks.
PrimaryKeyIter
An iterator over the variants of PrimaryKey
RelationIter
An iterator over the variants of Relation
ScheduledTaskDbStore
SeaORM-backed scheduled task store.

Enums§

Column
Generated by sea-orm-macros
PrimaryKey
Generated by sea-orm-macros
Relation

Constants§

SCHEDULED_TASKS_TABLE
Scheduled task table name.
SCHEDULED_TASK_CLAIM_EXPIRES_AT_COLUMN
Current claim expiry column.
SCHEDULED_TASK_CLAIM_OWNER_ID_COLUMN
Current claim owner column.
SCHEDULED_TASK_CREATED_AT_COLUMN
Row creation timestamp column.
SCHEDULED_TASK_DISPLAY_NAME_COLUMN
Operator-facing display name column.
SCHEDULED_TASK_ID_COLUMN
Stable row identifier column.
SCHEDULED_TASK_LAST_CLAIMED_AT_COLUMN
Last claim timestamp column.
SCHEDULED_TASK_LAST_FINISHED_AT_COLUMN
Last completion timestamp column.
SCHEDULED_TASK_NAMESPACE_COLUMN
Product namespace column.
SCHEDULED_TASK_NAMESPACE_NAME_UNIQUE_INDEX
Unique index name for one task per namespace/name pair.
SCHEDULED_TASK_NAME_COLUMN
Product task name column.
SCHEDULED_TASK_NEXT_RUN_AT_COLUMN
Next due timestamp column.
SCHEDULED_TASK_NEXT_RUN_INDEX
Index name for due-time claim scans.
SCHEDULED_TASK_UPDATED_AT_COLUMN
Row update timestamp column.

Functions§

create_scheduled_tasks_namespace_name_unique_index
Builds the unique index for one scheduled task per namespace/name pair.
create_scheduled_tasks_next_run_index
Builds the due-time index used by scheduled task claim checks.
create_scheduled_tasks_table
Builds the shared scheduled_tasks table creation statement.
drop_scheduled_tasks_table
Builds the shared scheduled_tasks table drop statement.