Struct mz_storage_client::types::sources::LoadGeneratorSourceConnection

pub struct LoadGeneratorSourceConnection {
    pub load_generator: LoadGenerator,
    pub tick_micros: Option<u64>,
}

Fields

load_generator: LoadGenerator

tick_micros: Option<u64>

Trait Implementations

impl Arbitrary for LoadGeneratorSourceConnection

type Parameters = (<LoadGenerator as Arbitrary>::Parameters, <Option<u64> as Arbitrary>::Parameters)

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

type Strategy = Map<(<LoadGenerator as Arbitrary>::Strategy, <Option<u64> as Arbitrary>::Strategy), fn(_: (LoadGenerator, Option<u64>)) -> LoadGeneratorSourceConnection>

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 LoadGeneratorSourceConnection

fn clone(&self) -> LoadGeneratorSourceConnection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LoadGeneratorSourceConnection

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LoadGeneratorSourceConnection

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

Deserialize this value from the given Serde deserializer.

impl From<LoadGeneratorSourceConnection> for GenericSourceConnection

fn from(conn: LoadGeneratorSourceConnection) -> Self

Converts to this type from the input type.

impl PartialEq<LoadGeneratorSourceConnection> for LoadGeneratorSourceConnection

fn eq(&self, other: &LoadGeneratorSourceConnection) -> 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<ProtoLoadGeneratorSourceConnection> for LoadGeneratorSourceConnection

fn into_proto(&self) -> ProtoLoadGeneratorSourceConnection

Convert a Self into a Proto value.

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

Consume and convert a Proto back into a Self value.

impl Serialize for LoadGeneratorSourceConnection

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 LoadGeneratorSourceConnection

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 LoadGeneratorSourceConnection

impl StructuralEq for LoadGeneratorSourceConnection

impl StructuralPartialEq for LoadGeneratorSourceConnection