public class org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry extends java.lang.Object
{
static final java.lang.String METRIC_GROUP_NAME;
static final java.lang.String TOPIC_METRIC_GROUP_NAME;
private final java.util.List allTemplates;
public final org.apache.kafkaesqueesque.common.MetricName batchSizeAvg;
public final org.apache.kafkaesqueesque.common.MetricName batchSizeMax;
public final org.apache.kafkaesqueesque.common.MetricName compressionRateAvg;
public final org.apache.kafkaesqueesque.common.MetricName recordQueueTimeAvg;
public final org.apache.kafkaesqueesque.common.MetricName recordQueueTimeMax;
public final org.apache.kafkaesqueesque.common.MetricName requestLatencyAvg;
public final org.apache.kafkaesqueesque.common.MetricName requestLatencyMax;
public final org.apache.kafkaesqueesque.common.MetricName produceThrottleTimeAvg;
public final org.apache.kafkaesqueesque.common.MetricName produceThrottleTimeMax;
public final org.apache.kafkaesqueesque.common.MetricName recordSendRate;
public final org.apache.kafkaesqueesque.common.MetricName recordSendTotal;
public final org.apache.kafkaesqueesque.common.MetricName recordsPerRequestAvg;
public final org.apache.kafkaesqueesque.common.MetricName recordRetryRate;
public final org.apache.kafkaesqueesque.common.MetricName recordRetryTotal;
public final org.apache.kafkaesqueesque.common.MetricName recordErrorRate;
public final org.apache.kafkaesqueesque.common.MetricName recordErrorTotal;
public final org.apache.kafkaesqueesque.common.MetricName recordSizeMax;
public final org.apache.kafkaesqueesque.common.MetricName recordSizeAvg;
public final org.apache.kafkaesqueesque.common.MetricName requestsInFlight;
public final org.apache.kafkaesqueesque.common.MetricName metadataAge;
public final org.apache.kafkaesqueesque.common.MetricName batchSplitRate;
public final org.apache.kafkaesqueesque.common.MetricName batchSplitTotal;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendRate;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendTotal;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteRate;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteTotal;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicCompressionRate;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryRate;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryTotal;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorRate;
private final org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorTotal;
private final org.apache.kafkaesqueesque.common.metrics.Metrics metrics;
private final java.util.Set tags;
private final java.util.LinkedHashSet topicTags;
public void <init>(org.apache.kafkaesqueesque.common.metrics.Metrics)
{
org.apache.kafkaesqueesque.common.MetricName v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
java.util.Map v;
java.util.Set v, v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.common.metrics.Metrics v, v;
java.util.LinkedHashSet v, v;
org.apache.kafkaesqueesque.common.metrics.MetricConfig v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: org.apache.kafkaesqueesque.common.metrics.Metrics;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics> = v;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.metrics.MetricConfig config()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.MetricConfig: java.util.Map tags()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.Set tags> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.List allTemplates> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("batch-size-avg", "The average number of bytes sent per partition per-request.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName batchSizeAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("batch-size-max", "The max number of bytes sent per partition per-request.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName batchSizeMax> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("compression-rate-avg", "The average compression rate of record batches.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName compressionRateAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-queue-time-avg", "The average time in ms record batches spent in the send buffer.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordQueueTimeAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-queue-time-max", "The maximum time in ms record batches spent in the send buffer.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordQueueTimeMax> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("request-latency-avg", "The average request latency in ms");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName requestLatencyAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("request-latency-max", "The maximum request latency in ms");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName requestLatencyMax> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-send-rate", "The average number of records sent per second.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordSendRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-send-total", "The total number of records sent.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordSendTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("records-per-request-avg", "The average number of records per request.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordsPerRequestAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-retry-rate", "The average per-second number of retried record sends");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordRetryRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-retry-total", "The total number of retried record sends");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordRetryTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-error-rate", "The average per-second number of record sends that resulted in errors");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordErrorRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-error-total", "The total number of record sends that resulted in errors");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordErrorTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-size-max", "The maximum record size");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordSizeMax> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("record-size-avg", "The average record size");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName recordSizeAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("requests-in-flight", "The current number of in-flight requests awaiting a response.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName requestsInFlight> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("metadata-age", "The age in seconds of the current producer metadata being used.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName metadataAge> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("batch-split-rate", "The average number of batch splits per second");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName batchSplitRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("batch-split-total", "The total number of batch splits");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName batchSplitTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("produce-throttle-time-avg", "The average time in ms a request was throttled by a broker");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName produceThrottleTimeAvg> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String,java.lang.String)>("produce-throttle-time-max", "The maximum time in ms a request was throttled by a broker");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricName produceThrottleTimeMax> = v;
v = new java.util.LinkedHashSet;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.Set tags>;
specialinvoke v.<java.util.LinkedHashSet: void <init>(java.util.Collection)>(v);
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.LinkedHashSet topicTags> = v;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.LinkedHashSet topicTags>;
virtualinvoke v.<java.util.LinkedHashSet: boolean add(java.lang.Object)>("topic");
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-send-rate", "The average number of records sent per second for a topic.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-send-total", "The total number of records sent for a topic.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("byte-rate", "The average number of bytes sent per second for a topic.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("byte-total", "The total number of bytes sent for a topic.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("compression-rate", "The average compression rate of record batches for a topic.");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicCompressionRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-retry-rate", "The average per-second number of retried record sends for a topic");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-retry-total", "The total number of retried record sends for a topic");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryTotal> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-error-rate", "The average per-second number of record sends that resulted in errors for a topic");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorRate> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String,java.lang.String)>("record-error-total", "The total number of record sends that resulted in errors for a topic");
v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorTotal> = v;
return;
}
private org.apache.kafkaesqueesque.common.MetricName createMetricName(java.lang.String, java.lang.String)
{
java.util.Set v;
java.lang.String[] v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.lang.String v, v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.Set tags>;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTemplate(java.lang.String,java.lang.String,java.lang.String,java.util.Set)>(v, "producer-metrics", v, v);
v = newarray (java.lang.String)[0];
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.lang.String[])>(v, v);
return v;
}
private org.apache.kafkaesqueesque.common.MetricNameTemplate createTopicTemplate(java.lang.String, java.lang.String)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
java.lang.String v, v;
java.util.LinkedHashSet v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.LinkedHashSet topicTags>;
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate createTemplate(java.lang.String,java.lang.String,java.lang.String,java.util.Set)>(v, "producer-topic-metrics", v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordSendRate(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendRate>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordSendTotal(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordSendTotal>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicByteRate(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteRate>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicByteTotal(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicByteTotal>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicCompressionRate(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicCompressionRate>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordRetryRate(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryRate>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordRetryTotal(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordRetryTotal>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordErrorRate(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorRate>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public org.apache.kafkaesqueesque.common.MetricName topicRecordErrorTotal(java.util.Map)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
java.util.Map v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.MetricNameTemplate topicRecordErrorTotal>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.MetricName metricInstance(org.apache.kafkaesqueesque.common.MetricNameTemplate,java.util.Map)>(v, v);
return v;
}
public java.util.List allTemplates()
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
java.util.List v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.List allTemplates>;
return v;
}
public org.apache.kafkaesqueesque.common.metrics.Sensor sensor(java.lang.String)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
org.apache.kafkaesqueesque.common.metrics.Sensor v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.metrics.Sensor sensor(java.lang.String)>(v);
return v;
}
public void addMetric(org.apache.kafkaesqueesque.common.MetricName, org.apache.kafkaesqueesque.common.metrics.Measurable)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Measurable v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
org.apache.kafkaesqueesque.common.MetricName v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: org.apache.kafkaesqueesque.common.MetricName;
v := @parameter: org.apache.kafkaesqueesque.common.metrics.Measurable;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: void addMetric(org.apache.kafkaesqueesque.common.MetricName,org.apache.kafkaesqueesque.common.metrics.Measurable)>(v, v);
return;
}
public org.apache.kafkaesqueesque.common.metrics.Sensor getSensor(java.lang.String)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
org.apache.kafkaesqueesque.common.metrics.Metrics v;
org.apache.kafkaesqueesque.common.metrics.Sensor v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.lang.String;
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: org.apache.kafkaesqueesque.common.metrics.Metrics metrics>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.metrics.Metrics: org.apache.kafkaesqueesque.common.metrics.Sensor getSensor(java.lang.String)>(v);
return v;
}
private org.apache.kafkaesqueesque.common.MetricNameTemplate createTemplate(java.lang.String, java.lang.String, java.lang.String, java.util.Set)
{
org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry v;
java.util.List v;
java.util.Set v;
org.apache.kafkaesqueesque.common.MetricNameTemplate v;
java.lang.String v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.Set;
v = new org.apache.kafkaesqueesque.common.MetricNameTemplate;
specialinvoke v.<org.apache.kafkaesqueesque.common.MetricNameTemplate: void <init>(java.lang.String,java.lang.String,java.lang.String,java.util.Set)>(v, v, v, v);
v = v.<org.apache.kafkaesqueesque.clients.producer.internals.SenderMetricsRegistry: java.util.List allTemplates>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
}