Trait mz_storage_client::types::sources::SourceConnection
source · pub trait SourceConnection: Clone {
fn name(&self) -> &'static str;
fn upstream_name(&self) -> Option<&str>;
fn timestamp_desc(&self) -> RelationDesc;
fn num_outputs(&self) -> usize;
fn connection_id(&self) -> Option<GlobalId>;
fn metadata_columns(&self) -> Vec<(&str, ColumnType)> ⓘ;
fn metadata_column_types(&self) -> Vec<IncludedColumnSource> ⓘ;
}Expand description
A connection to an external system
Required Methods§
sourcefn upstream_name(&self) -> Option<&str>
fn upstream_name(&self) -> Option<&str>
The name of the resource in the external system (e.g kafka topic) if any
sourcefn timestamp_desc(&self) -> RelationDesc
fn timestamp_desc(&self) -> RelationDesc
The schema of this connection’s timestamp type. This will also be the schema of the progress relation.
sourcefn num_outputs(&self) -> usize
fn num_outputs(&self) -> usize
The number of outputs. This will be 1 for sources with no subsources or 1 + num_subsources otherwise.
sourcefn connection_id(&self) -> Option<GlobalId>
fn connection_id(&self) -> Option<GlobalId>
The id of the connection object (i.e the one obtained from running CREATE CONNECTION) in
the catalog, if any.
sourcefn metadata_columns(&self) -> Vec<(&str, ColumnType)> ⓘ
fn metadata_columns(&self) -> Vec<(&str, ColumnType)> ⓘ
Returns available metadata columns that this connection offers in (name, type) pairs in the order specified by the user.
sourcefn metadata_column_types(&self) -> Vec<IncludedColumnSource> ⓘ
fn metadata_column_types(&self) -> Vec<IncludedColumnSource> ⓘ
The available metadata columns in the order specified by the user. This only identifies the kinds of columns that this source offers without any further information.