Enum MessageType

pub enum MessageType {
    Default,
    BeginStream(String),
    EndStream(String),
}

MessageType is utilized by plugins to identiy which type of message are they sending to the runtime. MessageType::Default is utilized for processing data that will be sent to their configured outputs. MessageType::BeginStream and MessageType::EndStream will not be processed by the pipeline but are utilized to logically group messages together under a shared callback function.

Variants

Default

Default message to be processed

BeginStream(String)

Received from Input modules that indicates the start of an event stream with a shared callback This event is used for tracking state only and will not be processed

EndStream(String)

Received from Input modules that indicates the end of an event stream with a shared callback This event is used for tracking state only and will not be processed

Trait Implementations

impl Clone for MessageType

fn clone(&self) -> MessageType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageType

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

Formats the value using the given formatter.

impl Default for MessageType

fn default() -> MessageType

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MessageType

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MessageType

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

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 MessageType