class org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics extends java.lang.Object
{
public final org.apache.kafkaesque.common.metrics.Sensor retrySensor;
public final org.apache.kafkaesque.common.metrics.Sensor errorSensor;
public final org.apache.kafkaesque.common.metrics.Sensor queueTimeSensor;
public final org.apache.kafkaesque.common.metrics.Sensor requestTimeSensor;
public final org.apache.kafkaesque.common.metrics.Sensor recordsPerRequestSensor;
public final org.apache.kafkaesque.common.metrics.Sensor batchSizeSensor;
public final org.apache.kafkaesque.common.metrics.Sensor compressionRateSensor;
public final org.apache.kafkaesque.common.metrics.Sensor maxRecordSizeSensor;
public final org.apache.kafkaesque.common.metrics.Sensor batchSplitSensor;
private final org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics;
private final org.apache.kafkaesque.common.utils.Time time;
public void <init>(org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry, org.apache.kafkaesque.clients.Metadata, org.apache.kafkaesque.clients.KafkaClient, org.apache.kafkaesque.common.utils.Time)
{
org.apache.kafkaesque.common.metrics.stats.Avg v, v, v, v, v, v;
org.apache.kafkaesque.common.MetricName v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
org.apache.kafkaesque.clients.KafkaClient v;
org.apache.kafkaesque.common.utils.Time v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v, v, v;
org.apache.kafkaesque.common.metrics.stats.Max v, v, v, v;
org.apache.kafkaesque.clients.Metadata v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v, v, v;
org.apache.kafkaesque.common.metrics.Measurable v, v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: org.apache.kafkaesque.clients.Metadata;
v := @parameter: org.apache.kafkaesque.clients.KafkaClient;
v := @parameter: org.apache.kafkaesque.common.utils.Time;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics> = v;
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.utils.Time time> = v;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("batch-size");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSizeSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSizeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName batchSizeAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSizeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName batchSizeMax>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("compression-rate");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor compressionRateSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor compressionRateSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName compressionRateAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("queue-time");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor queueTimeSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor queueTimeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordQueueTimeAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor queueTimeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordQueueTimeMax>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("request-time");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor requestTimeSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor requestTimeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName requestLatencyAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor requestTimeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName requestLatencyMax>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("records-per-request");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsPerRequestSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsPerRequestSensor>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordSendRate>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordSendTotal>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsPerRequestSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordsPerRequestAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("record-retries");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor retrySensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor retrySensor>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordRetryRate>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordRetryTotal>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("errors");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor errorSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor errorSensor>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordErrorRate>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordErrorTotal>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("record-size");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor maxRecordSizeSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor maxRecordSizeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordSizeMax>;
v = new org.apache.kafkaesque.common.metrics.stats.Max;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Max: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor maxRecordSizeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName recordSizeAvg>;
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName requestsInFlight>;
v = staticinvoke <org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics$lambda_new_0__467: org.apache.kafkaesque.common.metrics.Measurable bootstrap$(org.apache.kafkaesque.clients.KafkaClient)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: void addMetric(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.Measurable)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName metadataAge>;
v = staticinvoke <org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics$lambda_new_1__468: org.apache.kafkaesque.common.metrics.Measurable bootstrap$(org.apache.kafkaesque.clients.Metadata)>(v);
virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: void addMetric(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.Measurable)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>("batch-split-rate");
v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSplitSensor> = v;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSplitSensor>;
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName batchSplitRate>;
v = v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName batchSplitTotal>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
return;
}
private void maybeRegisterTopicMetrics(java.lang.String)
{
java.util.Map v;
org.apache.kafkaesque.common.metrics.stats.Meter v, v, v, v;
org.apache.kafkaesque.common.metrics.stats.Avg v;
org.apache.kafkaesque.common.MetricName v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
java.lang.String v, v, v, v, v, v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: java.lang.String;
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[])>("topic.\u.records-per-batch");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("topic", v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordSendRate(java.util.Map)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordSendTotal(java.util.Map)>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("topic.\u.bytes");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicByteRate(java.util.Map)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicByteTotal(java.util.Map)>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("topic.\u.compression-rate");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicCompressionRate(java.util.Map)>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Avg;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Avg: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.MeasurableStat)>(v, 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[])>("topic.\u.record-retries");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordRetryRate(java.util.Map)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordRetryTotal(java.util.Map)>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(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[])>("topic.\u.record-errors");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor sensor(java.lang.String)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordErrorRate(java.util.Map)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.MetricName topicRecordErrorTotal(java.util.Map)>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Meter;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Meter: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.MetricName)>(v, v);
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: boolean add(org.apache.kafkaesque.common.metrics.CompoundStat)>(v);
label:
return;
}
public void updateProduceRequestMetrics(java.util.Map)
{
java.util.Map v;
boolean v, v;
java.util.Collection v;
org.apache.kafkaesque.common.metrics.Sensor v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.TopicPartition v;
long v, v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
int v, v, v, v, v, v;
org.apache.kafkaesque.common.utils.Time v;
java.lang.String v, v, v, v;
double v, v;
java.util.Iterator v, v;
java.lang.Object v, v, v, v, v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v, v, v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: org.apache.kafkaesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
specialinvoke v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: void maybeRegisterTopicMetrics(java.lang.String)>(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[])>("topic.\u.records-per-batch");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: int recordCount>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(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[])>("topic.\u.bytes");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: int estimatedSizeInBytes()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(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[])>("topic.\u.compression-rate");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: double compressionRatio()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSizeSensor>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: int estimatedSizeInBytes()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor queueTimeSensor>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: long queueTimeMs()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor compressionRateSensor>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: double compressionRatio()>();
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double)>(v);
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor maxRecordSizeSensor>;
v = v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: int maxRecordSize>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = v.<org.apache.kafkaesque.clients.producer.internals.ProducerBatch: int recordCount>;
v = v + v;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor recordsPerRequestSensor>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
goto label;
label:
return;
}
public void recordRetries(java.lang.String, int)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
long v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
int v;
org.apache.kafkaesque.common.utils.Time v;
java.lang.String v, v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor retrySensor>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, 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[])>("topic.\u.record-retries");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void recordErrors(java.lang.String, int)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
long v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
int v;
org.apache.kafkaesque.common.utils.Time v;
java.lang.String v, v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor errorSensor>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, 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[])>("topic.\u.record-errors");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
public void recordLatency(java.lang.String, long)
{
org.apache.kafkaesque.common.metrics.Sensor v, v;
long v, v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
org.apache.kafkaesque.common.utils.Time v;
java.lang.String v, v;
org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry v;
boolean v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v := @parameter: java.lang.String;
v := @parameter: long;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor requestTimeSensor>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
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[])>("node-\u.latency");
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry metrics>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record(double,long)>(v, v);
label:
return;
}
void recordBatchSplit()
{
org.apache.kafkaesque.common.metrics.Sensor v;
org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics v;
v := @this: org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics;
v = v.<org.apache.kafkaesque.clients.producer.internals.Sender$SenderMetrics: org.apache.kafkaesque.common.metrics.Sensor batchSplitSensor>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.Sensor: void record()>();
return;
}
}