public class org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics extends java.lang.Object implements java.lang.AutoCloseable
{
private final org.apache.kafkaesqueesqueesque.common.MetricName lastPollMetricName;
private final org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor;
private final org.apache.kafkaesqueesqueesque.common.metrics.Sensor pollIdleSensor;
private final org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics;
private long lastPollMs;
private long pollStartMs;
private long timeSinceLastPollMs;
public void <init>(org.apache.kafkaesqueesqueesque.common.metrics.Metrics, java.lang.String)
{
org.apache.kafkaesqueesqueesque.common.metrics.Metrics v;
org.apache.kafkaesqueesqueesque.common.MetricName v, v, v, v, v;
java.lang.String v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics v;
org.apache.kafkaesqueesqueesque.common.metrics.Measurable v;
org.apache.kafkaesqueesqueesque.common.metrics.stats.Avg v, v;
org.apache.kafkaesqueesqueesque.common.metrics.Sensor v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.metrics.stats.Max v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics;
v := @parameter: org.apache.kafkaesqueesqueesque.common.metrics.Metrics;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics> = v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001-metrics");
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics$lambda_new_0__201: org.apache.kafkaesqueesqueesque.common.metrics.Measurable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String)>("last-poll-seconds-ago", v, "The number of seconds since the last poll() invocation.");
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.MetricName lastPollMetricName> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.MetricName lastPollMetricName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: void addMetric(org.apache.kafkaesqueesqueesque.common.MetricName,org.apache.kafkaesqueesqueesque.common.metrics.Measurable)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor sensor(java.lang.String)>("time-between-poll");
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String)>("time-between-poll-avg", v, "The average delay between invocations of poll().");
v = new org.apache.kafkaesqueesqueesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: boolean add(org.apache.kafkaesqueesqueesque.common.MetricName,org.apache.kafkaesqueesqueesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String)>("time-between-poll-max", v, "The max delay between invocations of poll().");
v = new org.apache.kafkaesqueesqueesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: boolean add(org.apache.kafkaesqueesqueesque.common.MetricName,org.apache.kafkaesqueesqueesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor sensor(java.lang.String)>("poll-idle-ratio-avg");
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor pollIdleSensor> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor pollIdleSensor>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.MetricName metricName(java.lang.String,java.lang.String,java.lang.String)>("poll-idle-ratio-avg", v, "The average fraction of time the consumer\'s poll() is idle as opposed to waiting for the user code to process records.");
v = new org.apache.kafkaesqueesqueesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: boolean add(org.apache.kafkaesqueesqueesque.common.MetricName,org.apache.kafkaesqueesqueesque.common.metrics.MeasurableStat)>(v, v);
return;
}
public void recordPollStart(long)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics v;
long v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.metrics.Sensor v;
byte v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics;
v := @parameter: long;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long pollStartMs> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long lastPollMs>;
v = v cmp 0L;
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long lastPollMs>;
v = v - v;
goto label;
label:
v = 0L;
label:
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long timeSinceLastPollMs> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long timeSinceLastPollMs>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: void record(double)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long lastPollMs> = v;
return;
}
public void recordPollEnd(long)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics v;
long v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.metrics.Sensor v;
double v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long pollStartMs>;
v = v - v;
v = v * 1.0;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: long timeSinceLastPollMs>;
v = v + v;
v = v / v;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor pollIdleSensor>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: void record(double)>(v);
return;
}
public void close()
{
org.apache.kafkaesqueesqueesque.common.metrics.Metrics v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics v;
org.apache.kafkaesqueesqueesque.common.metrics.Sensor v, v;
org.apache.kafkaesqueesqueesque.common.MetricName v;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.MetricName lastPollMetricName>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesqueesque.common.metrics.KafkaMetric removeMetric(org.apache.kafkaesqueesqueesque.common.MetricName)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor timeBetweenPollSensor>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: java.lang.String name()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: void removeSensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.KafkaConsumerMetrics: org.apache.kafkaesqueesqueesque.common.metrics.Sensor pollIdleSensor>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Sensor: java.lang.String name()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.metrics.Metrics: void removeSensor(java.lang.String)>(v);
return;
}
}