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

Specifies the message type. If MessageType::BeginStream or MessageType::EndStream 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 a queue and then processes all the lines in said file. Each line will be its own Message; where the stream callback will delete the original 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