Struct MockSourceConfig 

pub struct MockSourceConfig {
    pub data_type: DataType,
    pub interval_ms: u64,
}

Configuration for a MockSource instance.

Controls what type of data is generated and how frequently.

Example

use drasi_source_mock::{MockSourceConfig, DataType};

let config = MockSourceConfig {
    data_type: DataType::sensor_reading(10),
    interval_ms: 1000,
};

Serialization

This type supports serde serialization for configuration files:

data_type:
  type: sensor_reading
  sensor_count: 10
interval_ms: 1000

Fields

data_type: DataType

The type of synthetic data to generate.

Defaults to DataType::Generic if not specified.

interval_ms: u64

Interval between generated events in milliseconds.

Must be greater than 0. Defaults to 5000 (5 seconds) if not specified.

Implementations

impl MockSourceConfig

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

Validates this configuration.

Errors

Returns anyhow::Error if:

• interval_ms is 0 (would cause a spin loop with no delay between events)
• data_type is SensorReading with sensor_count of 0 (must have at least one sensor)

Example

use drasi_source_mock::{MockSourceConfig, DataType};

let valid_config = MockSourceConfig {
    data_type: DataType::Counter,
    interval_ms: 1000,
};
assert!(valid_config.validate().is_ok());

let invalid_config = MockSourceConfig {
    data_type: DataType::Counter,
    interval_ms: 0,  // Invalid!
};
assert!(invalid_config.validate().is_err());

Trait Implementations

impl Clone for MockSourceConfig

fn clone(&self) -> MockSourceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MockSourceConfig

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

Formats the value using the given formatter.

impl Default for MockSourceConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MockSourceConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MockSourceConfig

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for MockSourceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MockSourceConfig