Struct KoreSchema 

pub struct KoreSchema {
    pub current_version: SchemaVersion,
    pub columns: Vec<SchemaField>,
    pub column_index: HashMap<String, usize>,
    pub aliases: HashMap<String, String>,
    pub history: Vec<SchemaHistoryEntry>,
    pub deleted_columns: BTreeMap<String, SchemaField>,
    pub type_conversions: HashMap<String, TypeConversionRule>,
}

Complete schema at a specific version

Fields

current_version: SchemaVersion

Current version number

columns: Vec<SchemaField>

Active (non-deleted) columns

column_index: HashMap<String, usize>

Map from column name to column index

aliases: HashMap<String, String>

Column name aliases (old_name → new_name)

history: Vec<SchemaHistoryEntry>

Complete history of all changes

deleted_columns: BTreeMap<String, SchemaField>

Deleted columns (for recovery)

type_conversions: HashMap<String, TypeConversionRule>

Type conversion registry

Implementations

impl KoreSchema

pub fn new(initial_columns: Vec<KColumn>) -> Self

Create a new schema with initial columns

pub fn get_column(&self, name: &str) -> Option<&SchemaField>

Get a column by name (handles aliases)

pub fn add_column( &mut self, name: String, column_type: KType, nullable: bool, default_value: Option<KVal>, author: String, reason: String, ) -> Result<(), String>

Add a new column

pub fn remove_column( &mut self, name: &str, author: String, reason: String, ) -> Result<(), String>

Remove a column (lazy deletion - mark as deleted)

pub fn rename_column( &mut self, old_name: &str, new_name: &str, author: String, reason: String, ) -> Result<(), String>

Rename a column (maintains backward compatibility via aliases)

pub fn change_type( &mut self, column_name: &str, new_type: KType, conversion_rule: TypeConversionRule, author: String, reason: String, ) -> Result<(), String>

Evolve a column’s type

pub fn set_nullable( &mut self, column_name: &str, nullable: bool, author: String, reason: String, ) -> Result<(), String>

Modify column nullability

pub fn active_columns(&self) -> Vec<&SchemaField>

Get all active (non-deleted) columns

pub fn num_active_columns(&self) -> usize

Get number of active columns

pub fn has_column(&self, name: &str) -> bool

Check if a column exists and is active

pub fn get_history(&self) -> &[SchemaHistoryEntry]

Get the history of changes

pub fn get_schema_at_version( &self, target_version: SchemaVersion, ) -> Result<KoreSchema, String>

Get schema at a specific version (reconstruct from history)

pub fn is_backward_compatible(&self) -> bool

Validate backward compatibility: can old readers read new data?

pub fn is_forward_compatible(&self) -> bool

Validate forward compatibility: can new readers read old data?

Trait Implementations

impl Clone for KoreSchema

fn clone(&self) -> KoreSchema

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KoreSchema

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.