Struct DatagenSourceConfig 

#[non_exhaustive]
pub struct DatagenSourceConfig {
    pub dataset: Dataset,
    pub encoding: Encoding,
    pub partitions: u32,
    pub seed: u64,
    pub tick_interval: Duration,
    pub events_per_tick: u32,
    pub count: Option<u64>,
    pub clock: Clock,
    pub epoch_ms: i64,
}

Configuration of a DatagenSource.

Every key has a default, so source: { datagen: {} } is a complete section.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

dataset: Dataset

The built-in dataset to generate.

encoding: Encoding

Wire format of the payloads.

partitions: u32

How many lanes to run, and therefore how many framework partitions the pipeline sees. Each lane owns a disjoint slice of the order-id space and generates independently; no lane ever reads another’s state. At least 1, and at most 1024.

seed: u64

Seed of the whole stream. Lane i derives its own stream from it, so changing partitions reshuffles which lane mints which order but leaves each lane reproducible.

tick_interval: Duration

How often a lane releases a batch. 0s means unthrottled: the lane generates as fast as the pipeline consumes, which is what a throughput measurement wants and what a demo does not.

events_per_tick: u32

Events released per lane per tick. Ignored when unthrottled. At least 1.

count: Option<u64>

Stop after this many events across all lanes, then drain the pipeline to a clean exit. Absent means the stream never ends.

clock: Clock

Where event timestamps come from.

epoch_ms: i64

Base instant for the fixed clock, in milliseconds since the Unix epoch. Ignored by the wall clock.

Implementations

impl DatagenSourceConfig

pub fn from_component_config( section: &ComponentConfig, ) -> Result<Self, ConfigError>

Deserialize and validate from the pipeline’s opaque component section.

pub fn validate(&self) -> Result<(), ConfigError>

Cross-field validation.

Trait Implementations

impl Clone for DatagenSourceConfig

fn clone(&self) -> DatagenSourceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatagenSourceConfig

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

Formats the value using the given formatter.

impl Default for DatagenSourceConfig

fn default() -> DatagenSourceConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DatagenSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for DatagenSourceConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DatagenSourceConfig