Module meta 

Modules

backup_meta 🔒

cluster_info 🔒

connection 🔒

pause_resume 🔒

reschedule 🔒

resume_backfill 🔒

serving 🔒

source_props 🔒

Structs

ReschedulePayload

WorkerReschedulePlan

Enums

RescheduleInput

Functions

alter_source_properties_safe

Alter source connector properties with pause/resume orchestration.

backup_meta

cluster_info

delete_meta_snapshots

get_cluster_info

inject_source_offsets

Inject specific offsets into source splits.

list_connections

list_serving_fragment_mappings

pause

reschedule

reset_source_splits

Reset source split assignments.

resume

resume_backfill

source_split_info

unregister_workers

validate_source