Enum Event 

pub enum Event {
    SessionAttached {
        session_id: SessionId,
        role: Role,
    },
    SessionDetached {
        session_id: SessionId,
    },
    TaskCreated {
        task_id: TaskId,
    },
    TaskAttemptStarted {
        task_id: TaskId,
        attempt: u32,
    },
    TaskAttemptCompleted {
        task_id: TaskId,
        attempt: u32,
        result: Value,
    },
    TaskPass {
        task_id: TaskId,
        result: Value,
    },
    TaskBlocked {
        task_id: TaskId,
        result: Value,
    },
    WorkerOutput {
        task_id: TaskId,
        attempt: u32,
        event: OutputEvent,
    },
    TaskSuspended {
        task_id: TaskId,
        key: ResumeKey,
    },
    TaskResumed {
        task_id: TaskId,
        key: ResumeKey,
    },
    TaskCancelled {
        task_id: TaskId,
    },
    SeniorQueried {
        task_id: TaskId,
        question: Value,
    },
    SeniorAnswered {
        task_id: TaskId,
        answer: Value,
    },
}

Engine lifecycle event. Every event is both appended to EngineState.event_log_tail (in-process ring buffer) and broadcast on Engine::event_tx for live subscribers.

Variants

SessionAttached

A session was attached (attach / attach_with / attach_with_ids).

Fields

session_id: SessionId

The newly attached session.

role: Role

Role its token was minted with.

SessionDetached

A session was detached (detach, or a heartbeat-miss timeout).

Fields

session_id: SessionId

The session that was detached.

TaskCreated

A new task was created via start_task.

Fields

task_id: TaskId

The newly created task.

TaskAttemptStarted

An attempt began dispatching (not currently emitted by dispatch_attempt_with; reserved for future use).

Fields

task_id: TaskId

The task being dispatched.

attempt: u32

The attempt number.

TaskAttemptCompleted

An attempt finished, Pass or Blocked, with the resulting value.

Fields

task_id: TaskId

The task whose attempt completed.

attempt: u32

The attempt number that completed.

result: Value

The result value produced by the attempt.

TaskPass

The task attempt completed with ok = true.

Fields

task_id: TaskId

The task that passed.

result: Value

The result value.

TaskBlocked

The task attempt completed with ok = false.

Fields

task_id: TaskId

The task that was blocked.

result: Value

The result/error value.

WorkerOutput

A worker appended an OutputEvent via submit_output.

Fields

task_id: TaskId

The task the output belongs to.

attempt: u32

The attempt the output belongs to.

event: OutputEvent

The appended output event.

TaskSuspended

The task suspended pending a resume for key.

Fields

task_id: TaskId

The suspended task.

key: ResumeKey

The key needed to resume it.

TaskResumed

The task resumed after resume(key, ..) was called.

Fields

task_id: TaskId

The resumed task.

key: ResumeKey

The key that was resumed.

TaskCancelled

The task was cancelled via cancel_task.

Fields

task_id: TaskId

The cancelled task.

SeniorQueried

query_senior was called, asking question on behalf of task_id.

Fields

task_id: TaskId

The task that triggered the query.

question: Value

The question posed to the Senior.

SeniorAnswered

A Senior’s answer was stored via resume.

Fields

task_id: TaskId

The task the answer applies to.

answer: Value

The Senior’s answer.

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Event

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.