Struct ObservedEvent 

pub struct ObservedEvent {
    pub cursor: u64,
    pub topic: String,
    pub received_at: String,
    pub reset_epoch: u64,
    pub payload: Value,
}

One captured event. Wire-shape returned by /events/{topic} endpoints.

Fields

cursor: u64

Server-assigned monotonic cursor within (topic, reset_epoch). Use it as the since= parameter on the next poll.

topic: String

Topic name — "orders", "pnl", "marketdata:265598", "gap".

received_at: String

RFC 3339 timestamp at which the connector pushed this into the ring.

reset_epoch: u64

Increments every time the underlying WS reconnects or the server restarts. Clients use it to detect “the cursor space reset under me”.

payload: Value

The decoded JSON frame. Shape depends on the topic — see the generated bezant-client TS types for the typed views.

Trait Implementations

impl Clone for ObservedEvent

fn clone(&self) -> ObservedEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObservedEvent

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

Formats the value using the given formatter.

impl Serialize for ObservedEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.