Struct SchemaEvolutionManager 

pub struct SchemaEvolutionManager { /* private fields */ }

Thread-safe registry that applies versioned SchemaMigrations to an ongoing stream without reconnecting.

Concurrency

The migration map is protected by a parking_lot::RwLock. Version counters use atomic operations so read-heavy workloads need no exclusive locks.

Implementations

impl SchemaEvolutionManager

pub fn new(initial_version: u64) -> Arc<Self>

Create a new manager starting at initial_version.

Returns an Arc-wrapped instance so it can be shared across tasks.

pub fn register_migration(&self, migration: SchemaMigration) -> bool

Register a migration.

Returns false if a migration for migration.from_version is already registered (duplicate registration is silently rejected).

pub fn migration_path( &self, from_version: u64, to_version: u64, ) -> Option<Vec<SchemaMigration>>

Compute the ordered sequence of migrations needed to go from from_version to to_version.

Only forward paths (strictly increasing version numbers) are supported. Returns None when no complete path exists.

pub fn migrate_to( &self, target_version: u64, ) -> Result<Vec<SchemaMigration>, MigrationError>

Apply all migrations necessary to reach target_version.

Errors

• MigrationError::AlreadyAtVersion — current version equals target.
• MigrationError::Downgrade — target is less than current version.
• MigrationError::NoPath — no registered path leads to target.

pub fn current_version(&self) -> u64

Return the current schema version.

pub fn applied_count(&self) -> u64

Return the total number of migrations applied since creation.

pub fn can_migrate(&self, from_version: u64, to_version: u64) -> bool

Return true when a migration path from from_version to to_version is available.

pub fn registered_versions(&self) -> Vec<u64>

Return all registered from_version values, in ascending order.