Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Schema registry for managing table definitions

Implementations

impl SchemaRegistry

pub fn new() -> SchemaRegistry

Create a new empty schema registry

pub fn version(&self) -> u32

Get the current schema version

pub fn create_table(&mut self, table: TableDef) -> Result<(), SchemaError>

Create a new table

pub fn drop_table(&mut self, name: &str) -> Result<TableDef, SchemaError>

Drop a table

pub fn get_table(&self, name: &str) -> Option<&TableDef>

Get a table definition by name

pub fn get_table_mut(&mut self, name: &str) -> Option<&mut TableDef>

Get a mutable table definition by name

pub fn list_tables(&self) -> Vec<&str>

List all table names

pub fn table_count(&self) -> usize

Get number of tables

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

Check if a table exists

pub fn add_column( &mut self, table_name: &str, column: ColumnDef, ) -> Result<(), SchemaError>

Add a column to an existing table

pub fn drop_column( &mut self, table_name: &str, column_name: &str, ) -> Result<(), SchemaError>

Drop a column from an existing table

pub fn create_index( &mut self, table_name: &str, index: IndexDef, ) -> Result<(), SchemaError>

Create an index on a table

pub fn drop_index( &mut self, table_name: &str, index_name: &str, ) -> Result<(), SchemaError>

Drop an index from a table

pub fn rename_table( &mut self, old_name: &str, new_name: &str, ) -> Result<(), SchemaError>

Rename a table

pub fn migrations(&self) -> &[Migration]

Get migration history

pub fn to_bytes(&self) -> Vec<u8>

Serialize the schema registry to bytes

pub fn from_bytes(data: &[u8]) -> Result<SchemaRegistry, SchemaError>

Deserialize from bytes

Trait Implementations

impl Default for SchemaRegistry

fn default() -> SchemaRegistry

Returns the “default value” for a type.

impl Display for SchemaRegistry

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

Formats the value using the given formatter.