Struct Message 

pub struct Message {
    pub bytes: Vec<u8>,
    pub metadata: HashMap<String, Value>,
    pub message_type: MessageType,
    pub stream_id: Option<String>,
}

Message is the uniform struct utilized within all modules of fiddler.

let content = "This is a message being processed";
let message = Message{
    bytes: content.as_bytes().into(),
    ..Default::default()
};

Fields

bytes: Vec<u8>

raw bytes of of the message to be collected, processed, and sent

metadata: HashMap<String, Value>

metadata about the message

message_type: MessageType

Specified message types. If [MessageType::Parent] is provided, no processing of the event will take place, but the callback will be called when all child messages have been processed. This gives modules the ability to tier callback actions. Such as a module that receives a file from queue and then processes all the lines in said file. Each line will be it’s own Message; where the parent callback will delete the message once all lines are processed

stream_id: Option<String>

[Optional] Specifies the stream_id of the associated stream of messages with a shared callback

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Default for Message

fn default() -> Message

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Message

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

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 Message