Struct ObservationEngineCheckpointV1

Source

pub struct ObservationEngineCheckpointV1 {
    pub version: u16,
    pub projections: Vec<SessionProjection>,
    pub cursor_journal: Vec<ObservationCheckpointCursorV1>,
    pub current_incarnations: Vec<ObservationCheckpointRouteV1>,
    pub retired_incarnations: Vec<ObservationCheckpointRouteV1>,
    pub managed_links: Vec<ManagedRecordLink>,
    pub transport_gaps: Vec<ObservationCheckpointRouteV1>,
    pub retention_floors: Vec<ObservationCheckpointRouteCursorV1>,
    pub high_watermarks: Vec<ObservationCheckpointRouteCursorV1>,
}

Fields§

§version: u16§projections: Vec<SessionProjection>§cursor_journal: Vec<ObservationCheckpointCursorV1>§current_incarnations: Vec<ObservationCheckpointRouteV1>§retired_incarnations: Vec<ObservationCheckpointRouteV1>§managed_links: Vec<ManagedRecordLink>§transport_gaps: Vec<ObservationCheckpointRouteV1>§retention_floors: Vec<ObservationCheckpointRouteCursorV1>§high_watermarks: Vec<ObservationCheckpointRouteCursorV1>

Struct ObservationEngineCheckpointV1 Copy item path

Fields§

Implementations§

impl ObservationEngineCheckpointV1

pub fn validate(&self) -> Result<(), ObservationEngineError>

Trait Implementations§

impl Clone for ObservationEngineCheckpointV1

fn clone(&self) -> Self

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

impl Debug for ObservationEngineCheckpointV1

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

impl<'de> Deserialize<'de> for ObservationEngineCheckpointV1

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Eq for ObservationEngineCheckpointV1

impl PartialEq for ObservationEngineCheckpointV1

fn eq(&self, other: &Self) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for ObservationEngineCheckpointV1

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

impl StructuralPartialEq for ObservationEngineCheckpointV1

Auto Trait Implementations§

impl Freeze for ObservationEngineCheckpointV1

impl RefUnwindSafe for ObservationEngineCheckpointV1

impl Send for ObservationEngineCheckpointV1

impl Sync for ObservationEngineCheckpointV1

impl Unpin for ObservationEngineCheckpointV1

impl UnsafeUnpin for ObservationEngineCheckpointV1

impl UnwindSafe for ObservationEngineCheckpointV1

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<T> CloneToUninit for Twhere T: Clone,

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

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

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> 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 = !

fn try_from(value: U) -> Result<T, !>

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> ⓘ

Struct ObservationEngineCheckpointV1

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

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<T> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

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

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>,