Struct mz_storage_types::sources::load_generator::KeyValueLoadGenerator

pub struct KeyValueLoadGenerator {
    pub keys: u64,
    pub snapshot_rounds: u64,
    pub transactional_snapshot: bool,
    pub value_size: u64,
    pub partitions: u64,
    pub tick_interval: Option<Duration>,
    pub batch_size: u64,
    pub seed: u64,
    pub include_offset: Option<String>,
}

Fields

keys: u64

The keyspace of the source.

snapshot_rounds: u64

The number of rounds to emit values for each key in the snapshot. This lets users scale the snapshot size independent of the keyspace.

Please use transactional_snapshot and non_transactional_snapshot_rounds.

transactional_snapshot: bool

When false, this lets us quickly produce updates, as opposed to a single-value per key during a transactional snapshot

value_size: u64

The number of random bytes for each value.

partitions: u64

The number of partitions. The keyspace is spread evenly across the partitions. This lets users scale the concurrency of the source independently of the replica size.

tick_interval: Option<Duration>

If provided, the maximum rate at which new batches of updates, per-partition will be produced after the snapshot.

batch_size: u64

The number of keys in each update batch.

seed: u64

A per-source seed.

include_offset: Option<String>

Whether or not to include the offset in the value. The string is the column name.

Implementations

impl KeyValueLoadGenerator

pub fn transactional_snapshot_rounds(&self) -> u64

The number of transactional snapshot rounds.

pub fn non_transactional_snapshot_rounds(&self) -> u64

The number of non-transactional snapshot rounds.

Trait Implementations

impl Arbitrary for KeyValueLoadGenerator

type Parameters = (<u64 as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters, <bool as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters, <Option<Duration> as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters, <u64 as Arbitrary>::Parameters, <Option<String> as Arbitrary>::Parameters)

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

type Strategy = Map<(<u64 as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy, <bool as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy, <Option<Duration> as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy, <u64 as Arbitrary>::Strategy, <Option<String> as Arbitrary>::Strategy), fn(_: (u64, u64, bool, u64, u64, Option<Duration>, u64, u64, Option<String>)) -> KeyValueLoadGenerator>

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 KeyValueLoadGenerator

fn clone(&self) -> KeyValueLoadGenerator

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for KeyValueLoadGenerator

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

Formats the value using the given formatter.

impl Default for KeyValueLoadGenerator

fn default() -> KeyValueLoadGenerator

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for KeyValueLoadGenerator

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for KeyValueLoadGenerator

fn eq(&self, other: &KeyValueLoadGenerator) -> 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 RustType<ProtoKeyValueLoadGenerator> for KeyValueLoadGenerator

fn into_proto(&self) -> ProtoKeyValueLoadGenerator

Convert a Self into a Proto value.

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

Consume and convert a Proto back into a Self value.

fn into_proto_owned(self) -> Proto

A zero clone version of Self::into_proto that types can optionally implement, otherwise, the default implementation delegates to Self::into_proto.

impl Serialize for KeyValueLoadGenerator

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for KeyValueLoadGenerator

impl StructuralPartialEq for KeyValueLoadGenerator