pub struct MobStructuralEventEnvelope {
pub event_id: String,
pub cursor: u64,
pub mob_id: String,
pub timestamp_ms: u64,
pub kind: String,
pub run_id: Option<String>,
pub step_id: Option<String>,
pub agent_identity: Option<String>,
pub mob_labels: BTreeMap<String, String>,
pub run_labels: BTreeMap<String, String>,
pub data: Value,
}Expand description
A structural mob event projected from meerkat_mob::AttributedEvent and
MobEventKind into a flat, identity-aware envelope suitable for SSE
replay and JSON-RPC query.
Mirrors the shape of crate::console_contracts::ConsoleIdentityEventEnvelope
but preserves structural fields (mob_id, run_id, step_id,
agent_identity) that the lossy UnifiedEvent::Agent projection
discards. cursor is a monotonically increasing sequence assigned at
ingestion time and serves as the pagination token (clients pass the
last-seen cursor as EventQuery::after_seq).
Fields§
§event_id: StringUnique event id (mirrors the originating mob event cursor when
available, prefixed with mob-evt-).
cursor: u64Monotonic ingestion sequence (used as after_seq cursor).
mob_id: StringMob this event belongs to.
timestamp_ms: u64Millisecond-precision wall-clock timestamp at ingestion.
kind: StringSnake-case event kind (e.g. flow_started, step_dispatched).
run_id: Option<String>Run id when the event is associated with a flow run, otherwise None.
step_id: Option<String>Step id when the event is associated with a flow step, otherwise None.
agent_identity: Option<String>Stable agent identity when the event is attributable to a member,
otherwise None.
mob_labels: BTreeMap<String, String>Mob-scoped labels at projection time (snapshot of the
RuntimeMetadataTable entry for MetadataScope::Mob(mob_id)).
Empty if no labels are set.
run_labels: BTreeMap<String, String>Run-scoped labels at projection time (snapshot of the
RuntimeMetadataTable entry for MetadataScope::Run(mob_id, run_id)).
Empty when the event has no run_id or no labels are set for the run.
data: ValueFull structured payload (the variant-specific fields of MobEventKind).
Trait Implementations§
Source§impl Clone for MobStructuralEventEnvelope
impl Clone for MobStructuralEventEnvelope
Source§fn clone(&self) -> MobStructuralEventEnvelope
fn clone(&self) -> MobStructuralEventEnvelope
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for MobStructuralEventEnvelope
impl Debug for MobStructuralEventEnvelope
Source§impl<'de> Deserialize<'de> for MobStructuralEventEnvelope
impl<'de> Deserialize<'de> for MobStructuralEventEnvelope
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>,
Source§impl PartialEq for MobStructuralEventEnvelope
impl PartialEq for MobStructuralEventEnvelope
Source§fn eq(&self, other: &MobStructuralEventEnvelope) -> bool
fn eq(&self, other: &MobStructuralEventEnvelope) -> bool
self and other values to be equal, and is used by ==.impl Eq for MobStructuralEventEnvelope
impl StructuralPartialEq for MobStructuralEventEnvelope
Auto Trait Implementations§
impl Freeze for MobStructuralEventEnvelope
impl RefUnwindSafe for MobStructuralEventEnvelope
impl Send for MobStructuralEventEnvelope
impl Sync for MobStructuralEventEnvelope
impl Unpin for MobStructuralEventEnvelope
impl UnsafeUnpin for MobStructuralEventEnvelope
impl UnwindSafe for MobStructuralEventEnvelope
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more