Class IpFilteringAuthStoreMetrics

java.lang.Object
io.confluent.security.auth.ipFiltering.IpFilteringAuthStoreMetrics
public class IpFilteringAuthStoreMetrics extends Object

  • Field Details

    • GROUP_NAME

      public static final String GROUP_NAME
      See Also:

    • IP_FILTERING_COUNT

      public static final String IP_FILTERING_COUNT
      See Also:

    • IP_FILTERING_ACCESS_RULE_COUNT

      public static final String IP_FILTERING_ACCESS_RULE_COUNT
      See Also:

    • RECORD_IP_FILTERING_LATENCY_GAUGE

      public static final String RECORD_IP_FILTERING_LATENCY_GAUGE
      See Also:

    • RECORD_IP_FILTERING_LATENCY_METRIC

      public static final String RECORD_IP_FILTERING_LATENCY_METRIC
      See Also:

    • recordsProcessedSensors

      public final EnumMap<io.confluent.security.auth.store.data.AuthEntryType, org.apache.kafka.common.metrics.Sensor> recordsProcessedSensors

  • Constructor Details

    • IpFilteringAuthStoreMetrics

      public IpFilteringAuthStoreMetrics(org.apache.kafka.common.metrics.Metrics metrics, IpFilteringAuthCache authCache)

  • Method Details

    • metrics

      public org.apache.kafka.common.metrics.Metrics metrics()

    • registerLatencyGauge

      public void registerLatencyGauge(String app, Supplier<Long> valueSupplier)

    • recordLatencyMetric

      public void recordLatencyMetric(io.confluent.security.auth.store.data.LatencyRecordKey latencyRecordKey, long latency)