pub struct Message<TCustom> {
pub data: MsgData<TCustom>,
pub key: String,
pub ts: Timestamp,
pub trace: MsgTrace,
}
Fields§
§data: MsgData<TCustom>
§key: String
§ts: Timestamp
§trace: MsgTrace
Implementations§
Source§impl<TCustom> Message<TCustom>where
TCustom: MsgDataBound,
impl<TCustom> Message<TCustom>where
TCustom: MsgDataBound,
pub fn new(data: MsgData<TCustom>) -> Self
pub fn new_custom(custom_data: TCustom) -> Self
pub fn get_data(&self) -> Option<TCustom>
pub fn add_trace_item(&mut self, id: &Uuid, name: &str)
Sourcepub fn contains_trace_item(&self, id: &Uuid) -> bool
pub fn contains_trace_item(&self, id: &Uuid) -> bool
Проверяем, что в трейсе сообщения присутсвует компонент с заданным id.
Полезно для предотварщения зацикливания сообщений, чтобы данный компонент не обрабатывал сообщения, которые он же и сгенерировал
Trait Implementations§
Source§impl<'de, TCustom> Deserialize<'de> for Message<TCustom>where
TCustom: Deserialize<'de>,
impl<'de, TCustom> Deserialize<'de> for Message<TCustom>where
TCustom: Deserialize<'de>,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl<TCustom> StructuralPartialEq for Message<TCustom>
Auto Trait Implementations§
impl<TCustom> Freeze for Message<TCustom>where
TCustom: Freeze,
impl<TCustom> RefUnwindSafe for Message<TCustom>where
TCustom: RefUnwindSafe,
impl<TCustom> Send for Message<TCustom>where
TCustom: Send,
impl<TCustom> Sync for Message<TCustom>where
TCustom: Sync,
impl<TCustom> Unpin for Message<TCustom>where
TCustom: Unpin,
impl<TCustom> UnwindSafe for Message<TCustom>where
TCustom: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more