pub struct ProxyState {
pub config: ProxyConfig,
pub http: Client<HttpConnector, Full<Bytes>>,
/* private fields */
}Expand description
Shared state used by every connection handler.
Fields§
§config: ProxyConfig§http: Client<HttpConnector, Full<Bytes>>Implementations§
Source§impl ProxyState
impl ProxyState
pub fn new(config: ProxyConfig) -> Arc<Self>
Sourcepub fn set_otel(&self, handle: TfOtelHandle)
pub fn set_otel(&self, handle: TfOtelHandle)
Install the process-wide OpenTelemetry handle. Should be called
at most once during startup, before run handles any traffic.
Uses OnceLock so this works through an Arc<Self>.
Sourcepub fn otel(&self) -> Option<&TfOtelHandle>
pub fn otel(&self) -> Option<&TfOtelHandle>
Borrow the OTel handle, if one was installed.
Auto Trait Implementations§
impl !Freeze for ProxyState
impl !RefUnwindSafe for ProxyState
impl !UnwindSafe for ProxyState
impl Send for ProxyState
impl Sync for ProxyState
impl Unpin for ProxyState
impl UnsafeUnpin for ProxyState
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