pub struct GapSignal {
pub skipped: u64,
pub last_seq: u64,
}Expand description
Payload of a gap SSE event on GET /api/agents/{id}/stream.
The bus dropped skipped events after last_seq because the subscriber
lagged (#28). The stream self-heals by replaying from the store, but the
signal is still sent so a client can say “some output was missed” rather
than silently rendering a discontinuous timeline.
Fields§
§skipped: u64How many events were dropped.
last_seq: u64The last sequence number delivered before the gap.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for GapSignal
impl<'de> Deserialize<'de> for GapSignal
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl Copy for GapSignal
impl Eq for GapSignal
impl StructuralPartialEq for GapSignal
Auto Trait Implementations§
impl Freeze for GapSignal
impl RefUnwindSafe for GapSignal
impl Send for GapSignal
impl Sync for GapSignal
impl Unpin for GapSignal
impl UnsafeUnpin for GapSignal
impl UnwindSafe for GapSignal
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more