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§

The name of the external system (e.g kafka, postgres, etc).

The name of the resource in the external system (e.g kafka topic) if any

The schema of this connection’s timestamp type. This will also be the schema of the progress relation.

The number of outputs. This will be 1 for sources with no subsources or 1 + num_subsources otherwise.

The id of the connection object (i.e the one obtained from running CREATE CONNECTION) in the catalog, if any.

Returns available metadata columns that this connection offers in (name, type) pairs in the order specified by the user.

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.