Struct SchemaEvolutionManager 

pub struct SchemaEvolutionManager { /* private fields */ }

Schema evolution manager

Implementations

impl SchemaEvolutionManager

pub fn new() -> Self

Create a new schema evolution manager

pub fn register_schema(&self, schema: SchemaDefinition) -> Result<String>

Register a new schema

pub fn evolve_schema( &self, schema_name: &str, changes: Vec<SchemaChange>, user: String, ) -> Result<EvolutionResult>

Evolve a schema with new changes

pub fn get_schema( &self, schema_name: &str, version: &str, ) -> Result<SchemaVersion>

Get a specific schema version

pub fn get_active_schema(&self, schema_name: &str) -> Result<SchemaVersion>

Get the active schema version

pub fn migrate_event( &self, event: &StreamEvent, from_version: &str, to_version: &str, schema_name: &str, ) -> Result<StreamEvent>

Migrate event to a specific schema version

pub fn deprecate_version( &self, schema_name: &str, version: &str, reason: String, sunset_date: Option<DateTime<Utc>>, ) -> Result<()>

Deprecate a schema version

pub fn get_evolution_history( &self, schema_name: &str, ) -> Vec<SchemaEvolutionEvent>

Get evolution history

Trait Implementations

impl Default for SchemaEvolutionManager

fn default() -> Self

Returns the “default value” for a type.