Enum TurnEvent 

pub enum TurnEvent {
    QueuedWorkStarted {
        boundary: QueuedWorkClaimBoundary,
        batch_ids: Vec<String>,
        causes: Vec<TurnCause>,
    },
    ModelRequestStarted {
        protocol_iteration: usize,
    },
    AssistantProseDelta {
        text: Arc<str>,
    },
    ReasoningDelta {
        text: Arc<str>,
    },
    ModelAttemptReset {
        assistant_prose_correlation_ids: Vec<TurnActivityId>,
        reasoning_correlation_ids: Vec<TurnActivityId>,
    },
    CodeBlockStarted {
        language: String,
        code: String,
        graph_key: Option<String>,
    },
    CodeBlockCompleted {
        language: String,
        output: String,
        error: Option<String>,
        success: bool,
        duration_ms: u64,
        tool_call_ids: Vec<String>,
        graph_key: Option<String>,
    },
    ToolCallStarted {
        call_id: Option<String>,
        name: String,
        args: Value,
        graph_key: Option<String>,
        parent_call_id: Option<String>,
    },
    ToolCallCompleted {
        call_id: Option<String>,
        name: String,
        args: Value,
        output: ToolCallOutput,
        duration_ms: u64,
        graph_key: Option<String>,
        parent_call_id: Option<String>,
    },
    FinalValue {
        value: Value,
    },
    ToolValue {
        tool_name: String,
        value: Value,
    },
    Usage {
        protocol_iteration: usize,
        usage: TokenUsage,
        cumulative: TokenUsage,
    },
    ChildUsage {
        session_id: String,
        source: String,
        model: String,
        protocol_iteration: usize,
        usage: TokenUsage,
        cumulative: TokenUsage,
    },
    RetryStatus {
        wait_seconds: u64,
        attempt: usize,
        max_attempts: usize,
        reason: String,
    },
    PluginRuntime {
        plugin_id: String,
        event: PluginRuntimeEvent,
    },
    QueuedInputAccepted {
        checkpoint: CheckpointKind,
        inputs: Vec<AcceptedInjectedTurnInput>,
    },
    QueuedMessagesCommitted {
        messages: Vec<PluginMessage>,
        checkpoint: CheckpointKind,
    },
    Error {
        message: String,
    },
}

App-facing semantic event payload for a turn activity.

Unlike SessionStreamEvent, these events are stable application signals rather than low-level runtime/debug events. Public streams carry these payloads inside TurnActivity so every emitted item has identity.

Variants

QueuedWorkStarted

Fields

boundary: QueuedWorkClaimBoundary

batch_ids: Vec<String>

causes: Vec<TurnCause>

ModelRequestStarted

Fields

protocol_iteration: usize

AssistantProseDelta

Fields

text: Arc<str>

ReasoningDelta

Fields

text: Arc<str>

ModelAttemptReset

Retracts visible text emitted by a provider attempt that will be retried.

Observers remove only prose and reasoning deltas whose correlation ids appear here. The reset is itself replayed in order, so reconnecting observers converge on the same visible text as live observers.

Fields

assistant_prose_correlation_ids: Vec<TurnActivityId>

reasoning_correlation_ids: Vec<TurnActivityId>

CodeBlockStarted

Fields

language: String

code: String

graph_key: Option<String>

CodeBlockCompleted

Fields

language: String

output: String

error: Option<String>

success: bool

duration_ms: u64

tool_call_ids: Vec<String>

graph_key: Option<String>

ToolCallStarted

Fields

call_id: Option<String>

name: String

args: Value

graph_key: Option<String>

Graph key of the enclosing code block, when this tool call ran inside one. None when the call did not run inside a code block.

parent_call_id: Option<String>

Call id of the parent batch tool call, when this call is a child of a batch dispatch. None for top-level tool calls.

ToolCallCompleted

Fields

call_id: Option<String>

name: String

args: Value

output: ToolCallOutput

duration_ms: u64

graph_key: Option<String>

Graph key of the enclosing code block, when this tool call ran inside one. None when the call did not run inside a code block.

parent_call_id: Option<String>

Call id of the parent batch tool call, when this call is a child of a batch dispatch. None for top-level tool calls.

FinalValue

Fields

value: Value

ToolValue

Fields

tool_name: String

value: Value

Usage

Fields

protocol_iteration: usize

usage: TokenUsage

cumulative: TokenUsage

ChildUsage

Fields

session_id: String

source: String

model: String

protocol_iteration: usize

usage: TokenUsage

cumulative: TokenUsage

RetryStatus

Fields

wait_seconds: u64

attempt: usize

max_attempts: usize

reason: String

PluginRuntime

Fields

plugin_id: String

event: PluginRuntimeEvent

QueuedInputAccepted

Fields

checkpoint: CheckpointKind

inputs: Vec<AcceptedInjectedTurnInput>

QueuedMessagesCommitted

Fields

messages: Vec<PluginMessage>

checkpoint: CheckpointKind

Error

Fields

message: String

Trait Implementations

impl Clone for TurnEvent

fn clone(&self) -> TurnEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TurnEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TurnEvent

fn deserialize<__D>( __deserializer: __D, ) -> Result<TurnEvent, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<TurnEvent> for RemoteTurnEvent

fn from(value: TurnEvent) -> RemoteTurnEvent

Converts to this type from the input type.

impl Serialize for TurnEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.