pub struct TracerService { /* private fields */ }Expand description
Service for managing OpenTelemetry tracing
This service handles the configuration and lifecycle of OpenTelemetry tracing, including span export to a collector endpoint.
§Fields
name- The service name used for identifying tracesendpoint- The OpenTelemetry collector endpoint URLconfig- Configuration options for the tracer
Implementations§
Source§impl TracerService
impl TracerService
Trait Implementations§
Source§impl BackgroundService for TracerService
impl BackgroundService for TracerService
Source§fn start<'life0, 'async_trait>(
&'life0 self,
shutdown: ShutdownWatch,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn start<'life0, 'async_trait>(
&'life0 self,
shutdown: ShutdownWatch,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Open telemetry background service, it will schedule export data to server.
Source§fn start_with_ready_notifier<'life0, 'async_trait>(
&'life0 self,
shutdown: Receiver<bool>,
ready_notifier: ServiceReadyNotifier,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: Sync + 'async_trait,
fn start_with_ready_notifier<'life0, 'async_trait>(
&'life0 self,
shutdown: Receiver<bool>,
ready_notifier: ServiceReadyNotifier,
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: Sync + 'async_trait,
This function is called when the pingora server tries to start all the
services. The background service should signal readiness by calling
ready_notifier.notify_ready() once initialization is complete.
The service can return at anytime or wait for the shutdown signal. Read moreAuto Trait Implementations§
impl Freeze for TracerService
impl RefUnwindSafe for TracerService
impl Send for TracerService
impl Sync for TracerService
impl Unpin for TracerService
impl UnsafeUnpin for TracerService
impl UnwindSafe for TracerService
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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::Request