Struct MigrationRunner 

pub struct MigrationRunner { /* private fields */ }

Migration runner that handles both built-in and user migrations.

Implementations

impl MigrationRunner

pub fn new(pool: PgPool) -> Self

pub async fn run(&self, user_migrations: Vec<Migration>) -> Result<()>

Run all pending migrations with mesh-safe locking.

This acquires an exclusive advisory lock before running migrations, ensuring only one node in the cluster runs migrations at a time.

pub async fn rollback(&self, count: usize) -> Result<Vec<String>>

Rollback N migrations (most recent first).

pub async fn status(&self, available: &[Migration]) -> Result<MigrationStatus>

Get the status of all migrations.