Enum RecoverableChatUpdate

Source

pub enum RecoverableChatUpdate {
    Event {
        id: RecoverableChatEventId,
        event: Arc<SessionObservationEvent>,
    },
    ReplayGap {
        snapshot: RecoverableChatSnapshot,
        gap: LiveReplayGap,
    },
    TerminalReplacement {
        id: RecoverableChatEventId,
        event: Arc<SessionObservationEvent>,
        snapshot: RecoverableChatSnapshot,
    },
}

Expand description

Update yielded by RecoverableChatSubscription.

Variants§

§

Event

A provisional or lifecycle observation with stable redelivery identity.

Fields

§id: RecoverableChatEventId

§event: Arc<SessionObservationEvent>

§

ReplayGap

The requested cursor fell outside bounded replay. Replace the projection from snapshot, persist gap.latest_cursor, and continue consuming this same stream.

Fields

§snapshot: RecoverableChatSnapshot

§gap: LiveReplayGap

§

TerminalReplacement

A terminal commit replaces provisional state with this authoritative snapshot. The committed event is retained for remote encoding and tracing, but the snapshot is the transcript authority.

Fields

§id: RecoverableChatEventId

§event: Arc<SessionObservationEvent>

§snapshot: RecoverableChatSnapshot

RecoverableChatUpdate

Enum RecoverableChatUpdate Copy item path

Variants§

Event

Fields

ReplayGap

Fields

TerminalReplacement

Fields

Trait Implementations§

impl Clone for RecoverableChatUpdate

fn clone(&self) -> RecoverableChatUpdate

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

impl Debug for RecoverableChatUpdate

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

Auto Trait Implementations§

impl Freeze for RecoverableChatUpdate

impl RefUnwindSafe for RecoverableChatUpdate

impl Send for RecoverableChatUpdate

impl Sync for RecoverableChatUpdate

impl Unpin for RecoverableChatUpdate

impl UnsafeUnpin for RecoverableChatUpdate

impl UnwindSafe for RecoverableChatUpdate

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Enum RecoverableChatUpdate

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DynClone for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,