Struct console_subscriber::AggregatorHandle
source · pub struct AggregatorHandle { /* private fields */ }Expand description
Aggregator handle.
This object is returned from Server::into_parts. It can be
used to abort the aggregator task.
The aggregator collects the traces that implement the async runtime being observed and prepares them to be served by the gRPC server.
Normally, if the server, started with Server::serve or
Server::serve_with stops for any reason, the aggregator is aborted,
hoewver, if the server was started with the InstrumentServer returned
from Server::into_parts, then it is the responsibility of the user
of the API to stop the aggregator task by calling abort on this
object.
Implementations§
source§impl AggregatorHandle
impl AggregatorHandle
sourcepub fn abort(&mut self)
pub fn abort(&mut self)
Aborts the task running this aggregator.
To avoid having a disconnected aggregator running forever, this
method should be called when the tonic::transport::Server started
with the InstrumentServer also returned from Server::into_parts
stops running.
Auto Trait Implementations§
impl RefUnwindSafe for AggregatorHandle
impl Send for AggregatorHandle
impl Sync for AggregatorHandle
impl Unpin for AggregatorHandle
impl UnwindSafe for AggregatorHandle
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
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>
T in a tonic::Request