Struct ContinuousTemporalDefinition

Source

pub struct ContinuousTemporalDefinition {Show 19 fields
    pub format_version: u32,
    pub evaluation_id: Identity,
    pub pattern_generation: U64,
    pub inputs: Vec<TemporalInput>,
    pub event_time_field: String,
    pub correlation_fields: Vec<String>,
    pub pattern: TemporalPattern,
    pub start: ContinuousTemporalStart,
    pub watermark_policy: ContinuousTemporalWatermarkPolicy,
    pub late_data_policy: ContinuousTemporalLateDataPolicy,
    pub maximum_events_per_step: u32,
    pub maximum_states: u32,
    pub maximum_captured_events: u32,
    pub maximum_results: u32,
    pub maximum_state_bytes: U64,
    pub maximum_lag_bytes: U64,
    pub maximum_lag_events: U64,
    pub maximum_lag_event_age_nanos: U64,
    pub output: ContinuousTemporalOutput,
}

Fields§

§format_version: u32§evaluation_id: Identity§pattern_generation: U64§inputs: Vec<TemporalInput>§event_time_field: String§correlation_fields: Vec<String>§pattern: TemporalPattern§start: ContinuousTemporalStart§watermark_policy: ContinuousTemporalWatermarkPolicy§late_data_policy: ContinuousTemporalLateDataPolicy§maximum_events_per_step: u32§maximum_states: u32§maximum_captured_events: u32§maximum_results: u32§maximum_state_bytes: U64§maximum_lag_bytes: U64§maximum_lag_events: U64§maximum_lag_event_age_nanos: U64§output: ContinuousTemporalOutput

ContinuousTemporalDefinition

Struct ContinuousTemporalDefinition Copy item path

Fields§

Trait Implementations§

impl Clone for ContinuousTemporalDefinition

fn clone(&self) -> ContinuousTemporalDefinition

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

impl Debug for ContinuousTemporalDefinition

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

impl<'de> Deserialize<'de> for ContinuousTemporalDefinition

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

impl PartialEq for ContinuousTemporalDefinition

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

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

impl Serialize for ContinuousTemporalDefinition

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

impl StructuralPartialEq for ContinuousTemporalDefinition

Auto Trait Implementations§

impl Freeze for ContinuousTemporalDefinition

impl RefUnwindSafe for ContinuousTemporalDefinition

impl Send for ContinuousTemporalDefinition

impl Sync for ContinuousTemporalDefinition

impl Unpin for ContinuousTemporalDefinition

impl UnsafeUnpin for ContinuousTemporalDefinition

impl UnwindSafe for ContinuousTemporalDefinition

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 ContinuousTemporalDefinition

fn deserialize<D>( deserializer: D, ) -> Result<ContinuousTemporalDefinition, <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>,