pub struct OpenTelemetryDownstream { /* private fields */ }
Implementations§
source§impl OpenTelemetryDownstream
impl OpenTelemetryDownstream
pub fn new(channel: ChannelType) -> Self
pub async fn send_batches_forever(&mut self, receiver: Receiver<Vec<Metric>>)
Auto Trait Implementations§
impl !RefUnwindSafe for OpenTelemetryDownstream
impl Send for OpenTelemetryDownstream
impl Sync for OpenTelemetryDownstream
impl Unpin for OpenTelemetryDownstream
impl !UnwindSafe for OpenTelemetryDownstream
Blanket Implementations§
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