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 cursor, strictly increasing per topic for the life of the process and seeded from the boot time so a restart does not rewind it. Always below 2^53. 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

The epoch this event was captured under. Seeded from the boot time (Unix ms) and incremented on every reconnect, so it changes on both a reconnect and a restart. Clients use it to detect a gap.

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.