pub struct CascadeMonitor { /* private fields */ }Expand description
A thread-safe store of active cascade sessions for introspection.
Useful for monitoring dashboards and the web API to surface how many cascades are running and their turn counts.
Implementations§
Source§impl CascadeMonitor
impl CascadeMonitor
Sourcepub async fn on_turn(&self, session_id: &str, turn: usize)
pub async fn on_turn(&self, session_id: &str, turn: usize)
Record that a cascade has completed another turn.
Sourcepub async fn on_complete(&self, session_id: &str)
pub async fn on_complete(&self, session_id: &str)
Record that a cascade has finished.
Sourcepub async fn active_count(&self) -> usize
pub async fn active_count(&self) -> usize
Return the number of active cascade sessions.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for CascadeMonitor
impl !UnwindSafe for CascadeMonitor
impl Freeze for CascadeMonitor
impl Send for CascadeMonitor
impl Sync for CascadeMonitor
impl Unpin for CascadeMonitor
impl UnsafeUnpin for CascadeMonitor
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request