Struct TestConfig

pub struct TestConfig {
    pub message_count: Option<u32>,
    pub max_messages_per_second: Option<u32>,
    pub seed: Option<u32>,
    pub message_size: Option<u32>,
    pub send_batch_on_register: Option<bool>,
    pub dummy_fields: Option<DummyFields>,
}

The configuration for a fake producer used in tests.

Fields

message_count: Option<u32>

The number of messages the fake producer should send.

max_messages_per_second: Option<u32>

The maximum number of messages which should be sent each second. The actual obserced speed may be lower if the producer is unable to work fast enough. If this is zero or unset, the producer will send as fast as possible.

seed: Option<u32>

The seed value for a simple multiplicative congruential pseudo-random number sequence.

message_size: Option<u32>

The size of each message in bytes. Should be greater than or equal 5 to account for the number of bytes needed to encode the random number and a null byte for the string.

send_batch_on_register: Option<bool>

Whether the producer should send a event batch when the data source is is initially registered.

dummy_fields: Option<DummyFields>

Implementations

impl TestConfig

pub fn message_count(&self) -> u32

Returns the value of message_count, or the default value if message_count is unset.

pub fn max_messages_per_second(&self) -> u32

Returns the value of max_messages_per_second, or the default value if max_messages_per_second is unset.

pub fn seed(&self) -> u32

Returns the value of seed, or the default value if seed is unset.

pub fn message_size(&self) -> u32

Returns the value of message_size, or the default value if message_size is unset.

pub fn send_batch_on_register(&self) -> bool

Returns the value of send_batch_on_register, or the default value if send_batch_on_register is unset.

Trait Implementations

impl Clone for TestConfig

fn clone(&self) -> TestConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TestConfig

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

Formats the value using the given formatter.

impl Default for TestConfig

fn default() -> Self

Returns the “default value” for a type.

impl Message for TestConfig

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for TestConfig

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