Struct Migrator 

pub struct Migrator<X> { /* private fields */ }

An ordered, idempotent set of migrations for one executor type X.

Implementations

impl<X: Executor> Migrator<X>

pub fn new() -> Self

pub fn add(self, m: impl Migration<X> + 'static) -> Self

Append a step (any Migration impl).

pub fn create_table<E: Entity + 'static>(self, name: &'static str) -> Self

Append a “create E’s table” step.

pub fn names(&self) -> Vec<&'static str>

The names of every step, in registration order — what a migration-runner port reports as defined(), and the source of the migration “head” used to dedupe boot-time runs. The port that reports it is defined by the consumer, not here.

pub async fn run(&self, db: &X) -> Result<Vec<&'static str>>

Apply every not-yet-applied step to db, recording each in _orm_migrations. Idempotent: re-running applies only new steps. Returns the names applied this run.

When db reports it is sharded (Executor::is_sharded), the sharding control tables (shards, shard_directory) are ensured on its global database first — the ORM owns that metadata, so no flavor declares it. A no-op on a single, unsharded database.

pub async fn run_on_each(&self, dbs: &[&X]) -> Result<()>

run against each executor in turn — the shard fan-out (every shard gets the same schema, tracked independently).

Trait Implementations

impl<X: Executor> Default for Migrator<X>

fn default() -> Self

Returns the “default value” for a type.