Struct DeserializerConfig

pub struct DeserializerConfig {
    pub queue_size: usize,
}

Fields

queue_size: usize

Maximum number of messages which can be queued before messages are dropped.

Trait Implementations

impl Config for DeserializerConfig

type Kind = DeserializerConfigParameterKind

Enum auto-generated by nodo with one variant for each parameter

type Aux = DeserializerConfigAux

Auxilary type which holds information about when parameters where last modified.

fn list_parameters() -> &'static [(Self::Kind, ParameterProperties)]

List all parameters and their properties

fn set_parameter( &mut self, kind: Self::Kind, value: ParameterValue, ) -> Result<(), ConfigSetParameterError>

Set a parameter

fn get_parameters(&self) -> Vec<(Self::Kind, ParameterValue)>

Get values of all parameters

fn set_parameters<I>(&mut self, items: I) -> Result<(), ConfigSetParameterError>

where I: IntoIterator<Item = (Self::Kind, ParameterValue)>,

Set multiple parameters

impl Default for DeserializerConfig

fn default() -> Self

Returns the “default value” for a type.