Struct ContinuousTemporalEvaluation

Source

pub struct ContinuousTemporalEvaluation {Show 17 fields
    pub format_version: u32,
    pub evaluation_id: Identity,
    pub generation: U64,
    pub revision: U64,
    pub definition_digest: Digest,
    pub definition: ContinuousTemporalDefinition,
    pub lifecycle: String,
    pub frontiers: Vec<ContinuousTemporalFrontier>,
    pub global_watermark_unix_nanos: Option<U64>,
    pub state_bytes: U64,
    pub active_states: U64,
    pub active_timers: U64,
    pub retained_results: U64,
    pub pending_emissions: U64,
    pub last_materialized_frontier_digest: Option<Digest>,
    pub retry_count: u32,
    pub gap: Option<ContinuousTemporalGap>,
}

Fields§

§format_version: u32§evaluation_id: Identity§generation: U64§revision: U64§definition_digest: Digest§definition: ContinuousTemporalDefinition§lifecycle: String§frontiers: Vec<ContinuousTemporalFrontier>§global_watermark_unix_nanos: Option<U64>§state_bytes: U64§active_states: U64§active_timers: U64§retained_results: U64§pending_emissions: U64§last_materialized_frontier_digest: Option<Digest>§retry_count: u32§gap: Option<ContinuousTemporalGap>

ContinuousTemporalEvaluation

Struct ContinuousTemporalEvaluation Copy item path

Fields§

Trait Implementations§

impl Clone for ContinuousTemporalEvaluation

fn clone(&self) -> ContinuousTemporalEvaluation

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

impl Debug for ContinuousTemporalEvaluation

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

impl<'de> Deserialize<'de> for ContinuousTemporalEvaluation

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

impl PartialEq for ContinuousTemporalEvaluation

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

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

impl Serialize for ContinuousTemporalEvaluation

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

impl StructuralPartialEq for ContinuousTemporalEvaluation

Auto Trait Implementations§

impl Freeze for ContinuousTemporalEvaluation

impl RefUnwindSafe for ContinuousTemporalEvaluation

impl Send for ContinuousTemporalEvaluation

impl Sync for ContinuousTemporalEvaluation

impl Unpin for ContinuousTemporalEvaluation

impl UnsafeUnpin for ContinuousTemporalEvaluation

impl UnwindSafe for ContinuousTemporalEvaluation

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

fn from_ref(input: &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> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

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

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

fn serialize<S>( &self, serializer: S, ) -> Result<<S as Serializer>::Ok, <S as Serializer>::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> FromRef<T> for T
where T: Clone,

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

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

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