pub struct MetricsFlusherWorker;Expand description
A worker that periodically flushes the internal metrics registry to broadcast subscribers.
Wraps the internal flush loop and runs it under a Supervisor. Must
only be added to a supervisor after initialize_metrics has been called – the flush loop
reads from the global recorder state set by that call.
Trait Implementations§
Source§impl Supervisable for MetricsFlusherWorker
impl Supervisable for MetricsFlusherWorker
Source§fn initialize<'life0, 'async_trait>(
&'life0 self,
process_shutdown: ProcessShutdown,
) -> Pin<Box<dyn Future<Output = Result<SupervisorFuture, InitializationError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn initialize<'life0, 'async_trait>(
&'life0 self,
process_shutdown: ProcessShutdown,
) -> Pin<Box<dyn Future<Output = Result<SupervisorFuture, InitializationError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Initializes the process asynchronously. Read more
Source§fn shutdown_strategy(&self) -> ShutdownStrategy
fn shutdown_strategy(&self) -> ShutdownStrategy
Returns the shutdown strategy for the process.
Auto Trait Implementations§
impl Freeze for MetricsFlusherWorker
impl RefUnwindSafe for MetricsFlusherWorker
impl Send for MetricsFlusherWorker
impl Sync for MetricsFlusherWorker
impl Unpin for MetricsFlusherWorker
impl UnsafeUnpin for MetricsFlusherWorker
impl UnwindSafe for MetricsFlusherWorker
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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::RequestSource§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> Track for T
impl<T> Track for T
§fn track_allocations(self, token: AllocationGroupToken) -> Tracked<Self>
fn track_allocations(self, token: AllocationGroupToken) -> Tracked<Self>
Instruments this type by attaching the given allocation group token, returning a
Tracked wrapper. Read more§fn in_current_allocation_group(self) -> Tracked<Self>
fn in_current_allocation_group(self) -> Tracked<Self>
Instruments this type by attaching the current allocation group, returning a
Tracked wrapper. Read more