public SubscriberMetrics()

in src/main/java/com/googlesource/gerrit/plugins/multisite/consumer/SubscriberMetrics.java [46:68]

• 22 lines of code
• 1 McCabe index (conditional complexity)

  public SubscriberMetrics(MetricMaker metricMaker, ReplicationStatus replicationStatus) {
    this.replicationStatus = replicationStatus;

    this.subscriberSuccessCounter =
        metricMaker.newCounter(
            "multi_site/subscriber/subscriber_message_consumer_counter",
            new Description("Number of messages consumed by the subscriber")
                .setRate()
                .setUnit("messages"),
            stringField(SUBSCRIBER_SUCCESS_COUNTER, "Subscriber message consumed count"));
    this.subscriberFailureCounter =
        metricMaker.newCounter(
            "multi_site/subscriber/subscriber_message_consumer_failure_counter",
            new Description("Number of messages failed to consume by the subscriber consumer")
                .setRate()
                .setUnit("errors"),
            stringField(SUBSCRIBER_FAILURE_COUNTER, "Subscriber failed to consume messages count"));
    metricMaker.newCallbackMetric(
        REPLICATION_LAG_SEC,
        Long.class,
        new Description("Replication lag (sec)").setGauge().setUnit(Description.Units.SECONDS),
        replicationStatus::getMaxLag);
  }