Enum HubEvent 

pub enum HubEvent {
    Execution {
        project_id: i64,
        script_name: String,
        execution_id: Option<String>,
        event: EngineEvent,
        seq: Option<i64>,
        at: Option<String>,
    },
    Registry(RegistryEvent),
    Bench(BenchEvent),
}

Variants

Execution

Fields

project_id: i64

script_name: String

execution_id: Option<String>

The execution row’s id. Lets subscribers filter out events from a different concurrent run of the same script — without it, two callers running the same script around the same time see each other’s events. Optional on the wire for back-compat with older servers that predate the field (#1042 / TS SDK HubEvent.payload.execution_id).

event: EngineEvent

seq: Option<i64>

Monotonic per-execution sequence number from the execution_events.id row that this broadcast accompanies. Optional on the wire — older subscribers ignore it; missing on reconnect-replay frames where we don’t have a row yet.

at: Option<String>

Server-side RFC3339 timestamp with ms precision. Same value the REST get_execution_events endpoint stamps on each event.

Registry(RegistryEvent)

Bench(BenchEvent)

A live bench-run lifecycle event (RunStarted / ResultRecorded / RunFinished). Previously dropped on the floor — and, because the hub batch was decoded as Vec<HubEvent> with no catch-all, a Bench frame co-occurring with Execution frames in the same batch dropped the entire batch. The per-element decode in sub::events plus this typed arm fix both halves (#bench-hub-events).

Trait Implementations

impl Clone for HubEvent

fn clone(&self) -> HubEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HubEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HubEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HubEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.