Enum mz_storage_client::types::sources::GenericSourceConnection

pub enum GenericSourceConnection {
    Kafka(KafkaSourceConnection),
    Postgres(PostgresSourceConnection),
    LoadGenerator(LoadGeneratorSourceConnection),
    TestScript(TestScriptSourceConnection),
}

Variants

Kafka(KafkaSourceConnection)

Postgres(PostgresSourceConnection)

LoadGenerator(LoadGeneratorSourceConnection)

TestScript(TestScriptSourceConnection)

Trait Implementations

impl Arbitrary for GenericSourceConnection

type Parameters = (<KafkaSourceConnection as Arbitrary>::Parameters, <PostgresSourceConnection as Arbitrary>::Parameters, <LoadGeneratorSourceConnection as Arbitrary>::Parameters, <TestScriptSourceConnection as Arbitrary>::Parameters)

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = Union<BoxedStrategy<GenericSourceConnection>>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

impl Clone for GenericSourceConnection

fn clone(&self) -> GenericSourceConnection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for GenericSourceConnection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GenericSourceConnection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
    __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<KafkaSourceConnection> for GenericSourceConnection

fn from(conn: KafkaSourceConnection) -> Self

Converts to this type from the input type.

impl From<LoadGeneratorSourceConnection> for GenericSourceConnection

fn from(conn: LoadGeneratorSourceConnection) -> Self

Converts to this type from the input type.

impl From<PostgresSourceConnection> for GenericSourceConnection

fn from(conn: PostgresSourceConnection) -> Self

Converts to this type from the input type.

impl From<TestScriptSourceConnection> for GenericSourceConnection

fn from(conn: TestScriptSourceConnection) -> Self

Converts to this type from the input type.

impl PartialEq<GenericSourceConnection> for GenericSourceConnection

fn eq(&self, other: &GenericSourceConnection) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RustType<ProtoSourceConnection> for GenericSourceConnection

fn into_proto(&self) -> ProtoSourceConnection

Convert a Self into a Proto value.

fn from_proto(proto: ProtoSourceConnection) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

impl Serialize for GenericSourceConnection

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where
    __S: Serializer,

Serialize this value into the given Serde serializer.

impl SourceConnection for GenericSourceConnection

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

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

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

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

fn timestamp_desc(&self) -> RelationDesc

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

fn num_outputs(&self) -> usize

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

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.

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.

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.

impl Eq for GenericSourceConnection

impl StructuralEq for GenericSourceConnection

impl StructuralPartialEq for GenericSourceConnection