Trait SourceConnection

Source

pub trait SourceConnection:
    Debug
    + Clone
    + PartialEq
    + AlterCompatible {
    // Required methods
    fn name(&self) -> &'static str;
    fn external_reference(&self) -> Option<&str>;
    fn default_key_desc(&self) -> RelationDesc;
    fn default_value_desc(&self) -> RelationDesc;
    fn timestamp_desc(&self) -> RelationDesc;
    fn connection_id(&self) -> Option<CatalogItemId>;
    fn primary_export_details(&self) -> SourceExportDetails;
    fn supports_read_only(&self) -> bool;
    fn prefers_single_replica(&self) -> bool;
}

Expand description

A connection to an external system

Required Methods§

Source

fn name(&self) -> &'static str

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

Source

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

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

Source

fn default_key_desc(&self) -> RelationDesc

Defines the key schema to use by default for this source connection type. This will be used for the primary export of the source and as the default pre-encoding key schema for the source.

Source

fn default_value_desc(&self) -> RelationDesc

Defines the value schema to use by default for this source connection type. This will be used for the primary export of the source and as the default pre-encoding value schema for the source.

Source

fn timestamp_desc(&self) -> RelationDesc

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

Source

fn connection_id(&self) -> Option<CatalogItemId>

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

Source

fn primary_export_details(&self) -> SourceExportDetails

If this source connection can output to a primary collection, contains the source-specific details of that export, else is set to SourceExportDetails::None to indicate that this source should not export to the primary collection.

Source