Struct mithril_aggregator::event_store::EventMessage

pub struct EventMessage {
    pub source: String,
    pub action: String,
    pub content: Value,
    pub headers: HashMap<String, String>,
}

Event that is sent from a thread to be persisted.

Fields

source: String

The source of the message shall be composed of the name of the thread that sends the message, the name of the method can be added to it, separated by :. Example: Runtime::update_beacon or HTTP::register_signer.

action: String

The action represent the action that is going to be declared and as such represents the type of the JSON content.

content: Value

JSON content of the message, its type is declared in the action property.

headers: HashMap<String, String>

Headers

Implementations

impl EventMessage

pub fn new<T>( source: &str, action: &str, content: &T, headers: Vec<(&str, &str)>, ) -> Self

where T: Serialize,

Instantiate a new EventMessage.

pub fn signer_registration( source: &str, signer_with_stake: &SignerWithStake, signer_node_version: Option<String>, epoch_str: &str, ) -> Self

Create a signer registration event message.

Trait Implementations

impl Clone for EventMessage

fn clone(&self) -> EventMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventMessage

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

Formats the value using the given formatter.

impl PartialEq for EventMessage

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