public KafkaEventsPublisherMetrics()

in src/main/java/com/googlesource/gerrit/plugins/kafka/publish/KafkaEventsPublisherMetrics.java [33:49]

16 lines of code
1 McCabe index (conditional complexity)


  public KafkaEventsPublisherMetrics(MetricMaker metricMaker) {

    this.brokerPublisherSuccessCounter =
        metricMaker.newCounter(
            "kafka/broker/broker_message_publisher_counter",
            new Description("Number of successfully published messages by the broker publisher")
                .setRate()
                .setUnit("messages"),
            stringField(PUBLISHER_SUCCESS_COUNTER, "Broker message published count"));
    this.brokerPublisherFailureCounter =
        metricMaker.newCounter(
            "kafka/broker/broker_message_publisher_failure_counter",
            new Description("Number of messages failed to publish by the broker publisher")
                .setRate()
                .setUnit("errors"),
            stringField(PUBLISHER_FAILURE_COUNTER, "Broker failed to publish message count"));
  }