Package io.grpc.util

Class OutlierDetectionLoadBalancer.EndpointTrackerMap

    • Nested Class Summary

      • Nested classes/interfaces inherited from class com.google.common.collect.ForwardingMap

        com.google.common.collect.ForwardingMap.StandardEntrySet, com.google.common.collect.ForwardingMap.StandardKeySet, com.google.common.collect.ForwardingMap.StandardValues

      • Nested classes/interfaces inherited from interface java.util.Map

        java.util.Map.Entry<K extends java.lang.Object,​V extends java.lang.Object>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      (package private) void cancelTracking()
      When OD gets disabled we need to uneject any subchannels that may have been ejected and to reset the ejection time multiplier.
      protected java.util.Map<java.util.Set<java.net.SocketAddress>,​OutlierDetectionLoadBalancer.EndpointTracker> delegate()  
      (package private) double ejectionPercentage()
      How many percent of the addresses have been ejected.
      (package private) void maybeUnejectOutliers​(java.lang.Long detectionTimerStartNanos)
      At the end of a timer run we need to decrement the ejection time multiplier for trackers that don't have ejected subchannels and uneject ones that have spent the maximum ejection time allowed.
      (package private) void putNewTrackers​(OutlierDetectionLoadBalancer.OutlierDetectionLoadBalancerConfig config, java.util.Set<java.util.Set<java.net.SocketAddress>> endpoints)
      Adds a new tracker for every given address.
      (package private) void resetCallCounters()
      Resets the call counters for all the trackers in the map.
      (package private) void swapCounters()
      Swaps the active and inactive counters for each tracker.
      (package private) void updateTrackerConfigs​(OutlierDetectionLoadBalancer.OutlierDetectionLoadBalancerConfig config)  

      • Methods inherited from class com.google.common.collect.ForwardingMap

        clear, containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, keySet, put, putAll, remove, size, standardClear, standardContainsKey, standardContainsValue, standardEquals, standardHashCode, standardIsEmpty, standardPutAll, standardRemove, standardToString, values

      • Methods inherited from class com.google.common.collect.ForwardingObject

        toString

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait

      • Methods inherited from interface java.util.Map

        compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

    • Constructor Detail

      • EndpointTrackerMap

        EndpointTrackerMap()

    • Method Detail

      • resetCallCounters

        void resetCallCounters()
        Resets the call counters for all the trackers in the map.

      • cancelTracking

        void cancelTracking()
        When OD gets disabled we need to uneject any subchannels that may have been ejected and to reset the ejection time multiplier.

      • swapCounters

        void swapCounters()
        Swaps the active and inactive counters for each tracker.

      • maybeUnejectOutliers

        void maybeUnejectOutliers​(java.lang.Long detectionTimerStartNanos)
        At the end of a timer run we need to decrement the ejection time multiplier for trackers that don't have ejected subchannels and uneject ones that have spent the maximum ejection time allowed.

      • ejectionPercentage

        double ejectionPercentage()
        How many percent of the addresses have been ejected.