Struct Message 

pub struct Message {
    pub id: String,
    pub payload: Arc<Value>,
    pub context: Value,
    pub audit_trail: Vec<AuditTrail>,
    pub errors: Vec<ErrorInfo>,
    /* private fields */
}

Fields

id: String

payload: Arc<Value>

context: Value

Unified context containing data, metadata, and temp_data

audit_trail: Vec<AuditTrail>

errors: Vec<ErrorInfo>

Errors that occurred during message processing

Implementations

impl Message

pub fn new(payload: Arc<Value>) -> Self

pub fn get_context_arc(&mut self) -> Arc<Value>

Get or create an Arc reference to the context This method returns a cached Arc if available, or creates and caches a new one

pub fn invalidate_context_cache(&mut self)

Invalidate the cached context Arc Call this whenever the context is modified

pub fn from_value(payload: &Value) -> Self

Convenience method for creating a message from a Value reference Note: This clones the entire Value. Use from_arc() to avoid cloning when possible.

pub fn from_arc(payload: Arc<Value>) -> Self

Create a message from an Arc directly, avoiding cloning

pub fn add_error(&mut self, error: ErrorInfo)

Add an error to the message

pub fn has_errors(&self) -> bool

Check if message has errors

pub fn data(&self) -> &Value

Get a reference to the data field in context

pub fn data_mut(&mut self) -> &mut Value

Get a mutable reference to the data field in context

pub fn metadata(&self) -> &Value

Get a reference to the metadata field in context

pub fn metadata_mut(&mut self) -> &mut Value

Get a mutable reference to the metadata field in context

pub fn temp_data(&self) -> &Value

Get a reference to the temp_data field in context

pub fn temp_data_mut(&mut self) -> &mut Value

Get a mutable reference to the temp_data field in context

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<'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 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.