Enum mz_sql::pure::references::ReferenceMetadata

pub(super) enum ReferenceMetadata {
    Postgres {
        table: PostgresTableDesc,
        database: String,
    },
    MySql(MySqlTableSchema),
    Kafka(String),
    LoadGenerator {
        name: String,
        desc: Option<RelationDesc>,
        namespace: String,
        output: LoadGeneratorOutput,
    },
}

Metadata about an available source reference retrieved from the upstream system.

Variants

Postgres

Fields

table: PostgresTableDesc

database: String

MySql(MySqlTableSchema)

Kafka(String)

LoadGenerator

Fields

name: String

desc: Option<RelationDesc>

namespace: String

output: LoadGeneratorOutput

Implementations

impl ReferenceMetadata

fn namespace(&self) -> Option<&str>

fn name(&self) -> &str

pub(super) fn postgres_desc(&self) -> Option<&PostgresTableDesc>

pub(super) fn mysql_table(&self) -> Option<&MySqlTableSchema>

pub(super) fn load_generator_desc(&self) -> Option<&Option<RelationDesc>>

pub(super) fn load_generator_output(&self) -> Option<&LoadGeneratorOutput>

pub(super) fn external_reference( &self, ) -> Result<UnresolvedItemName, IdentError>

Convert the reference metadata into an UnresolvedItemName representing the external reference, normalized for each source type to be stored as part of the relevant statement in the catalog.

Trait Implementations

impl Clone for ReferenceMetadata

fn clone(&self) -> ReferenceMetadata

Returns a copy of the value.

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

Performs copy-assignment from source.