Module meta 

Modules

backup_meta 🔒

cluster_info 🔒

connection 🔒

create_meta_store_schema 🔒

pause_resume 🔒

reschedule 🔒

resume_backfill 🔒

serving 🔒

source_props 🔒

Structs

CreateMetaStoreSchemaOpts

Options for MetaCommands::CreateMetaStoreSchema.

ReschedulePayload

WorkerReschedulePlan

Enums

RescheduleInput

Functions

alter_source_properties_safe

Alter source connector properties with pause/resume orchestration.

backup_meta

cluster_info

create_meta_store_schema

Apply all schema changes located under src/meta/model/migration to the meta store, mirroring the behavior of SqlMetaStore::up without needing a running meta node.

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