Struct ArrowSchemaModel 

pub struct ArrowSchemaModel {
    pub events: Vec<ArrowEventSchema>,
}

Unified obs_events table schema. Used by ParquetSink to pre- compute the file-level Arrow schema, by ClickHouseSink to emit the CREATE TABLE DDL, and by obs migrate {parquet,clickhouse} for CI-driven migrations. Spec 14 § 4 / KD5 + spec 22 § 1.

Fields

events: Vec<ArrowEventSchema>

Per-event payload structs, sorted by full_name.

Implementations

impl ArrowSchemaModel

pub fn from_schemas<'a, I>(iter: I) -> Self

where I: IntoIterator<Item = &'a (dyn EventSchemaErased + 'static)>,

Build the model by walking a sequence of schemas. Sorted output makes downstream codegen byte-identical across runs (spec 12 § 1.2).

pub fn len(&self) -> usize

Number of registered event types.

pub fn is_empty(&self) -> bool

True if no events are registered.

pub fn lookup(&self, full_name: &str) -> Option<&ArrowEventSchema>

Look up one event’s struct by full_name.

pub fn to_json(&self) -> Result<String, Error>

Emit the model as a stable JSON string. Used by obs migrate parquet and as the snapshot format for CI diffing. Output is deterministic.

Errors

Returns serde_json::Error if serialization fails (cannot happen in practice for our owned structures).

Trait Implementations

impl Clone for ArrowSchemaModel

fn clone(&self) -> ArrowSchemaModel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ArrowSchemaModel

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

Formats the value using the given formatter.

impl Default for ArrowSchemaModel

fn default() -> ArrowSchemaModel

Returns the “default value” for a type.