pub struct TemporalRegistry { /* private fields */ }Expand description
Registry of temporal patterns evaluated on events and/or timer ticks.
Implementations§
Source§impl TemporalRegistry
impl TemporalRegistry
Sourcepub fn new() -> TemporalRegistry
pub fn new() -> TemporalRegistry
Create an empty registry.
Sourcepub fn register(&mut self, pattern: TemporalPattern)
pub fn register(&mut self, pattern: TemporalPattern)
Register a pattern.
Sourcepub fn check_all(
&self,
state: &State,
event: Option<&SessionEvent>,
writer: &Arc<dyn SessionWriter>,
) -> Vec<Pin<Box<dyn Future<Output = ()> + Send>>>
pub fn check_all( &self, state: &State, event: Option<&SessionEvent>, writer: &Arc<dyn SessionWriter>, ) -> Vec<Pin<Box<dyn Future<Output = ()> + Send>>>
Check all patterns and return the futures for those that fired.
Called by the control-lane processor on each event and optionally on a periodic timer tick.
Sourcepub fn needs_timer(&self) -> bool
pub fn needs_timer(&self) -> bool
Returns true if any registered pattern’s detector needs periodic
timer checks (i.e. its PatternDetector::needs_timer returns true).
Trait Implementations§
Source§impl Default for TemporalRegistry
impl Default for TemporalRegistry
Source§fn default() -> TemporalRegistry
fn default() -> TemporalRegistry
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for TemporalRegistry
impl !RefUnwindSafe for TemporalRegistry
impl Send for TemporalRegistry
impl Sync for TemporalRegistry
impl Unpin for TemporalRegistry
impl !UnwindSafe for TemporalRegistry
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
§impl<S> FromSample<S> for S
impl<S> FromSample<S> for S
fn from_sample_(s: S) -> S
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].