Struct CoreEventIdentity 

pub struct CoreEventIdentity {
    pub schema: String,
    pub identity: CoreIdentity,
    pub event_type: String,
    pub payload_digest: String,
    pub payload_bytes: u64,
    pub observed_at_ms: u64,
    pub event_digest: String,
}

Canonical digest-only identity for one runtime event.

Fields

schema: String

identity: CoreIdentity

event_type: String

payload_digest: String

payload_bytes: u64

observed_at_ms: u64

event_digest: String

Implementations

impl CoreEventIdentity

pub fn from_agent_event( identity: CoreIdentity, observed_at_ms: u64, event: &AgentEvent, ) -> Result<Self, CoreIdentityError>

pub fn from_agent_event_at( identity: CoreIdentity, clock: &dyn LogicalClock, event: &AgentEvent, ) -> Result<Self, CoreIdentityError>

Adapt an event using an injected logical clock instead of reading wall time in the caller. This keeps deterministic replay and tests separate from the system clock implementation.

pub fn from_run_event( operation_id: OperationId, source_revision: SourceRevision, capability_stamp: Option<CapabilityStamp>, record: &RunEventRecord, ) -> Result<Self, CoreIdentityError>

Adapt the event representation already retained by a Code run.

pub fn validate(&self) -> Result<(), CoreIdentityError>

pub fn expected_digest(&self) -> Result<String, CoreIdentityError>

Trait Implementations

impl Clone for CoreEventIdentity

fn clone(&self) -> CoreEventIdentity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoreEventIdentity

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CoreEventIdentity

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CoreEventIdentity

impl PartialEq for CoreEventIdentity

fn eq(&self, other: &CoreEventIdentity) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for CoreEventIdentity

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 CoreEventIdentity