Package io.micronaut.configuration.metrics.binder.web

Class WebMetricsPublisher<T extends io.micronaut.http.HttpResponse<?>>

java.lang.Object
reactor.core.publisher.Flux<T>
io.micronaut.configuration.metrics.binder.web.WebMetricsPublisher<T>
Type Parameters:
T - The response type
All Implemented Interfaces:
org.reactivestreams.Publisher<T>, reactor.core.CorePublisher<T>
@Deprecated(since="5.9", forRemoval=true) public class WebMetricsPublisher<T extends io.micronaut.http.HttpResponse<?>> extends reactor.core.publisher.Flux<T>
Deprecated, for removal: This API element is subject to removal in a future version.
No longer needed
Deals with the web filter metrics for success and error conditions.
Since:
1.0
Author:
Christian Oestreich, graemerocher

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    CLIENT_ERROR_URIS_ENABLED
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    static final String
    ENABLED
    Deprecated, for removal: This API element is subject to removal in a future version.
    To enable/disable web metrics.
    static final String
    METRIC_HTTP_CLIENT_REQUESTS
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    static final String
    METRIC_HTTP_SERVER_REQUESTS
    Deprecated, for removal: This API element is subject to removal in a future version.
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    subscribe(reactor.core.CoreSubscriber<? super T> actual)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Called for publisher.

    Methods inherited from class reactor.core.publisher.Flux

    all, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferUntilChanged, bufferUntilChanged, bufferUntilChanged, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, contextCapture, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, mapNotNull, materialize, merge, merge, merge, merge, merge, merge, mergeComparing, mergeComparing, mergeComparing, mergeComparingDelayError, mergeComparingWith, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergePriority, mergePriority, mergePriority, mergePriorityDelayError, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, shareNext, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, tap, tap, tap, then, then, thenEmpty, thenMany, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • ENABLED

      public static final String ENABLED
      Deprecated, for removal: This API element is subject to removal in a future version.
      To enable/disable web metrics.
      See Also:

    • CLIENT_ERROR_URIS_ENABLED

      public static final String CLIENT_ERROR_URIS_ENABLED
      Deprecated, for removal: This API element is subject to removal in a future version.
      See Also:

    • METRIC_HTTP_SERVER_REQUESTS

      public static final String METRIC_HTTP_SERVER_REQUESTS
      Deprecated, for removal: This API element is subject to removal in a future version.
      See Also:

    • METRIC_HTTP_CLIENT_REQUESTS

      public static final String METRIC_HTTP_CLIENT_REQUESTS
      Deprecated, for removal: This API element is subject to removal in a future version.
      See Also:

  • Method Details

    • subscribe

      public void subscribe(reactor.core.CoreSubscriber<? super T> actual)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Called for publisher.
      Specified by:
      subscribe in interface reactor.core.CorePublisher<T extends io.micronaut.http.HttpResponse<?>>
      Specified by:
      subscribe in class reactor.core.publisher.Flux<T extends io.micronaut.http.HttpResponse<?>>
      Parameters:
      actual - the original subscription