Struct RuntimeEvents 

pub struct RuntimeEvents {
    pub stream: Option<String>,
    pub include: Vec<String>,
    pub sampled: Vec<String>,
    pub queue: Option<u32>,
}

Which of the daemon’s own events reach a stream, and at what rate.

Fields

stream: Option<String>

The declared stream events land on. Required.

include: Vec<String>

Families taken in full (the segment before the first dot in an event name). Validated against the closed vocabulary at startup.

sampled: Vec<String>

Families taken at a sampled rate. A high-rate family cannot share a list with a once-a-week one: pressure.shed arrives in storms exactly when the disk it would be written to is the thing under pressure.

queue: Option<u32>

How many events may queue between ticks before the tap starts dropping (and counting). Default DEFAULT_TAP_QUEUE.

Implementations

impl RuntimeEvents

pub fn queue_cap(&self) -> usize

Trait Implementations

impl Clone for RuntimeEvents

fn clone(&self) -> RuntimeEvents

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeEvents

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

Formats the value using the given formatter.

impl Default for RuntimeEvents

fn default() -> RuntimeEvents

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RuntimeEvents

where RuntimeEvents: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RuntimeEvents

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RuntimeEvents