Enum ObsEvent 

pub enum ObsEvent {
    Sent {
        tick: u64,
        edge: Edge,
        session: SessionId,
        from: String,
        to: String,
        label: String,
    },
    Received {
        tick: u64,
        edge: Edge,
        session: SessionId,
        from: String,
        to: String,
        label: String,
    },
    Offered {
        tick: u64,
        edge: Edge,
        label: String,
    },
    Chose {
        tick: u64,
        edge: Edge,
        label: String,
    },
    Opened {
        tick: u64,
        session: SessionId,
        roles: Vec<String>,
    },
    Closed {
        tick: u64,
        session: SessionId,
    },
    SessionTerminal {
        tick: u64,
        session: SessionId,
        reason: SessionTerminalReason,
    },
    EpochAdvanced {
        tick: u64,
        sid: SessionId,
        epoch: usize,
    },
    Halted {
        tick: u64,
        coro_id: usize,
    },
    Invoked {
        tick: u64,
        coro_id: usize,
        role: String,
    },
    Acquired {
        tick: u64,
        session: SessionId,
        role: String,
        layer: String,
    },
    Released {
        tick: u64,
        session: SessionId,
        role: String,
        layer: String,
    },
    Transferred {
        tick: u64,
        session: SessionId,
        role: String,
        from: usize,
        to: usize,
    },
    Forked {
        tick: u64,
        session: SessionId,
        ghost: usize,
    },
    Joined {
        tick: u64,
        session: SessionId,
    },
    Aborted {
        tick: u64,
        session: SessionId,
    },
    Tagged {
        tick: u64,
        session: SessionId,
        role: String,
        fact: String,
    },
    Checked {
        tick: u64,
        session: SessionId,
        role: String,
        target: String,
        permitted: bool,
    },
    Faulted {
        tick: u64,
        coro_id: usize,
        fault: Fault,
    },
    FailureBranchEntered {
        tick: u64,
        session: SessionId,
        coro_id: usize,
        fault: Fault,
    },
    TimeoutIssued {
        tick: u64,
        site: String,
        until_tick: u64,
        witness_id: AuthorityWitnessId,
    },
    CancellationRequested {
        tick: u64,
        session: SessionId,
        witness_id: AuthorityWitnessId,
        owner_id: FragmentOwnerId,
        reason: OwnershipTerminalReason,
    },
    Cancelled {
        tick: u64,
        session: SessionId,
        witness_id: AuthorityWitnessId,
        reason: OwnershipTerminalReason,
    },
    OutputConditionChecked {
        tick: u64,
        predicate_ref: String,
        witness_ref: Option<String>,
        output_digest: String,
        passed: bool,
    },
}

Observable event emitted by the VM.

Variants

Sent

Value sent on an edge.

Fields

tick: u64

Scheduler tick when the event occurred.

edge: Edge

Session-scoped edge for this send.

session: SessionId

Session ID.

from: String

Sender role.

to: String

Receiver role.

label: String

Message label.

Received

Value received on an edge.

Fields

tick: u64

Scheduler tick when the event occurred.

edge: Edge

Session-scoped edge for this receive.

session: SessionId

Session ID.

from: String

Sender role.

to: String

Receiver role.

label: String

Message label.

Offered

Label offered on an edge.

Fields

tick: u64

Scheduler tick when the event occurred.

edge: Edge

Session-scoped edge for this offer.

label: String

Label offered.

Chose

Label chosen on an edge.

Fields

tick: u64

Scheduler tick when the event occurred.

edge: Edge

Session-scoped edge for this choice.

label: String

Label chosen.

Opened

Session opened.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

roles: Vec<String>

Participating roles.

Closed

Session closed.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

SessionTerminal

Explicit terminal transition for one session.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

reason: SessionTerminalReason

Explicit terminal reason.

EpochAdvanced

Session epoch advanced.

Fields

tick: u64

Scheduler tick when the event occurred.

sid: SessionId

Session ID.

epoch: usize

New epoch number.

Halted

Coroutine halted.

Fields

tick: u64

Scheduler tick when the event occurred.

coro_id: usize

Coroutine ID.

Invoked

Effect handler invoked.

Fields

tick: u64

Scheduler tick when the event occurred.

coro_id: usize

Coroutine ID.

role: String

Role name.

Acquired

Guard layer acquired.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

role: String

Role name.

layer: String

Guard layer identifier.

Released

Guard layer released.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

role: String

Role name.

layer: String

Guard layer identifier.

Transferred

Endpoint transferred between coroutines.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

role: String

Role name.

from: usize

Source coroutine.

to: usize

Target coroutine.

Forked

Speculation forked for a ghost session.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

ghost: usize

Ghost session id.

Joined

Speculation joined.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

Aborted

Speculation aborted.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

Tagged

Knowledge fact tagged.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

role: String

Role name.

fact: String

Fact payload.

Checked

Knowledge fact checked.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

role: String

Role name.

target: String

Target role.

permitted: bool

Whether the flow policy permitted the fact.

Faulted

Coroutine faulted.

Fields

tick: u64

Scheduler tick when the event occurred.

coro_id: usize

Coroutine ID.

fault: Fault

The fault.

FailureBranchEntered

Typed failure branch entry became visible before terminal fault handling.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

coro_id: usize

Coroutine ID.

fault: Fault

Failure that entered the branch.

TimeoutIssued

Explicit timeout occurrence became active for one site.

Fields

tick: u64

Scheduler tick when the event occurred.

site: String

Site that timed out.

until_tick: u64

Tick until which the timeout remains active.

witness_id: AuthorityWitnessId

Timeout witness issued for the occurrence.

CancellationRequested

Explicit cancellation path was requested.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

witness_id: AuthorityWitnessId

Cancellation witness issued for the request.

owner_id: FragmentOwnerId

Owner whose lifecycle triggered the cancellation.

reason: OwnershipTerminalReason

Ownership reason for the cancellation request.

Cancelled

Explicit cancellation path completed.

Fields

tick: u64

Scheduler tick when the event occurred.

session: SessionId

Session ID.

witness_id: AuthorityWitnessId

Cancellation witness used for the completion.

reason: OwnershipTerminalReason

Ownership reason for the completed cancellation.

OutputConditionChecked

Output-condition verification was evaluated at commit time.

Fields

tick: u64

Scheduler tick when the event occurred.

predicate_ref: String

Predicate reference that was checked.

witness_ref: Option<String>

Optional witness reference used by the check.

output_digest: String

Opaque output digest checked by the verifier.

passed: bool

Verification outcome.

Trait Implementations

impl Clone for ObsEvent

fn clone(&self) -> ObsEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObsEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ObsEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ObsEvent

impl PartialEq for ObsEvent

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

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 ObsEvent