Struct tremor_otelapis::opentelemetry::proto::metrics::experimental::metric_config_server::MetricConfigServer [−][src]
MetricConfig is a service that enables updating metric schedules, trace parameters, and other configurations on the SDK without having to restart the instrumented application. The collector can also serve as the configuration service, acting as a bridge between third-party configuration services and the SDK, piping updated configs from a third-party source to an instrumented application.
Implementations
impl<T: MetricConfig> MetricConfigServer<T>[src]
pub fn new(inner: T) -> Self[src]
pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self[src]
Trait Implementations
impl<T: MetricConfig> Clone for MetricConfigServer<T>[src]
fn clone(&self) -> Self[src]
pub fn clone_from(&mut self, source: &Self)1.0.0[src]
impl<T: Debug + MetricConfig> Debug for MetricConfigServer<T>[src]
impl<T, B> Service<Request<B>> for MetricConfigServer<T> where
T: MetricConfig,
B: HttpBody + Send + Sync + 'static,
B::Error: Into<StdError> + Send + 'static, [src]
T: MetricConfig,
B: HttpBody + Send + Sync + 'static,
B::Error: Into<StdError> + Send + 'static,
type Response = Response<BoxBody>
Responses given by the service.
type Error = Never
Errors produced by the service.
type Future = BoxFuture<Self::Response, Self::Error>
The future response value.
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>[src]
fn call(&mut self, req: Request<B>) -> Self::Future[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for MetricConfigServer<T>
impl<T> Send for MetricConfigServer<T>
impl<T> Sync for MetricConfigServer<T>
impl<T> Unpin for MetricConfigServer<T>
impl<T> !UnwindSafe for MetricConfigServer<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, ReqBody, ResBody> GrpcService<ReqBody> for T where
T: Service<Request<ReqBody>, Response = Response<ResBody>>,
ResBody: Body + Body,
<T as Service<Request<ReqBody>>>::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>,
<ResBody as Body>::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>, [src]
T: Service<Request<ReqBody>, Response = Response<ResBody>>,
ResBody: Body + Body,
<T as Service<Request<ReqBody>>>::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>,
<ResBody as Body>::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>,
type ResponseBody = ResBody
Responses body given by the service.
type Error = <T as Service<Request<ReqBody>>>::Error
Errors produced by the service.
type Future = <T as Service<Request<ReqBody>>>::Future
The future response value.
pub fn poll_ready(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), <T as GrpcService<ReqBody>>::Error>>[src]
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), <T as GrpcService<ReqBody>>::Error>>
pub fn call(
&mut self,
request: Request<ReqBody>
) -> <T as GrpcService<ReqBody>>::Future[src]
&mut self,
request: Request<ReqBody>
) -> <T as GrpcService<ReqBody>>::Future
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> IntoRequest<T> for T[src]
pub fn into_request(self) -> Request<T>[src]
impl<T, Request> ServiceExt<Request> for T where
T: Service<Request> + ?Sized, [src]
T: Service<Request> + ?Sized,
pub fn ready(&mut self) -> Ready<'_, Self, Request>[src]
pub fn ready_and(&mut self) -> Ready<'_, Self, Request>[src]
pub fn ready_oneshot(self) -> ReadyOneshot<Self, Request>[src]
pub fn oneshot(self, req: Request) -> Oneshot<Self, Request>[src]
pub fn call_all<S>(self, reqs: S) -> CallAll<Self, S> where
S: Stream<Item = Request>,
Self::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>, [src]
S: Stream<Item = Request>,
Self::Error: Into<Box<dyn Error + 'static + Sync + Send, Global>>,
pub fn and_then<F>(self, f: F) -> AndThen<Self, F> where
F: Clone, [src]
F: Clone,
pub fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F> where
F: FnOnce(Self::Response) -> Response + Clone, [src]
F: FnOnce(Self::Response) -> Response + Clone,
pub fn map_err<F, Error>(self, f: F) -> MapErr<Self, F> where
F: FnOnce(Self::Error) -> Error + Clone, [src]
F: FnOnce(Self::Error) -> Error + Clone,
pub fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F> where
Error: From<Self::Error>,
F: FnOnce(Result<Self::Response, Self::Error>) -> Result<Response, Error> + Clone, [src]
Error: From<Self::Error>,
F: FnOnce(Result<Self::Response, Self::Error>) -> Result<Response, Error> + Clone,
pub fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F> where
F: FnMut(NewRequest) -> Request + Clone, [src]
F: FnMut(NewRequest) -> Request + Clone,
pub fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F> where
Error: From<Self::Error>,
F: FnOnce(Result<Self::Response, Self::Error>) -> Fut + Clone,
Fut: Future<Output = Result<Response, Error>>, [src]
Error: From<Self::Error>,
F: FnOnce(Result<Self::Response, Self::Error>) -> Fut + Clone,
Fut: Future<Output = Result<Response, Error>>,
pub fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F> where
Error: From<Self::Error>,
F: FnMut(Self::Future) -> Fut,
Fut: Future<Output = Result<Response, Error>>, [src]
Error: From<Self::Error>,
F: FnMut(Self::Future) -> Fut,
Fut: Future<Output = Result<Response, Error>>,
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<T> WithSubscriber for T[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>, [src]
S: Into<Dispatch>,