public RMQMetricsCollector()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [179:269]
90 lines of code
1 McCabe index (conditional complexity)

    public RMQMetricsCollector(long outOfTimeSeconds) {
        this.topicOffset = initCache(outOfTimeSeconds);
        this.topicRetryOffset = initCache(outOfTimeSeconds);
        this.topicDLQOffset = initCache(outOfTimeSeconds);
        this.producerCounts = initCache(outOfTimeSeconds);
        this.topicPutNums = initCache(outOfTimeSeconds);
        this.topicPutSize = initCache(outOfTimeSeconds);

        this.consumerDiff = initCache(outOfTimeSeconds);
        this.consumerRetryDiff = initCache(outOfTimeSeconds);
        this.consumerDLQDiff = initCache(outOfTimeSeconds);
        this.consumerCounts = initCache(outOfTimeSeconds);
        this.consumerClientFailedMsgCounts = initCache(outOfTimeSeconds);
        this.consumerClientFailedTPS = initCache(outOfTimeSeconds);
        this.consumerClientOKTPS = initCache(outOfTimeSeconds);
        this.consumerClientRT = initCache(outOfTimeSeconds);
        this.consumerClientPullRT = initCache(outOfTimeSeconds);
        this.consumerClientPullTPS = initCache(outOfTimeSeconds);
        this.groupBrokerTotalOffset = initCache(outOfTimeSeconds);
        this.groupConsumeTotalOffset = initCache(outOfTimeSeconds);
        this.groupConsumeTPS = initCache(outOfTimeSeconds);
        this.groupGetNums = initCache(outOfTimeSeconds);
        this.groupGetSize = initCache(outOfTimeSeconds);
        this.sendBackNums = initCache(outOfTimeSeconds);
        this.groupLatencyByTime = initCache(outOfTimeSeconds);
        this.brokerPutNums = initCache(outOfTimeSeconds);
        this.brokerGetNums = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgPutTotalTodayNow = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgGetTotalTodayNow = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgGetTotalYesterdayMorning = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgPutTotalYesterdayMorning = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgGetTotalTodayMorning = initCache(outOfTimeSeconds);
        this.brokerRuntimeMsgPutTotalTodayMorning = initCache(outOfTimeSeconds);
        this.brokerRuntimeDispatchBehindBytes = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageSizeTotal = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageAverageSize = initCache(outOfTimeSeconds);
        this.brokerRuntimeQueryThreadPoolQueueCapacity = initCache(outOfTimeSeconds);
        this.brokerRuntimeRemainTransientStoreBufferNumbs = initCache(outOfTimeSeconds);
        this.brokerRuntimeEarliestMessageTimeStamp = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageEntireTimeMax = initCache(outOfTimeSeconds);
        this.brokerRuntimeStartAcceptSendRequestTimeStamp = initCache(outOfTimeSeconds);
        this.brokerRuntimeSendThreadPoolQueueSize = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageTimesTotal = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetMessageEntireTimeMax = initCache(outOfTimeSeconds);
        this.brokerRuntimePageCacheLockTimeMills = initCache(outOfTimeSeconds);
        this.brokerRuntimeCommitLogDiskRatio = initCache(outOfTimeSeconds);
        this.brokerRuntimeConsumeQueueDiskRatio = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetFoundTps600 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetFoundTps60 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetFoundTps10 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTotalTps600 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTotalTps60 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTotalTps10 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTransferedTps600 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTransferedTps60 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetTransferedTps10 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetMissTps600 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetMissTps60 = initCache(outOfTimeSeconds);
        this.brokerRuntimeGetMissTps10 = initCache(outOfTimeSeconds);
        this.brokerRuntimePutTps600 = initCache(outOfTimeSeconds);
        this.brokerRuntimePutTps60 = initCache(outOfTimeSeconds);
        this.brokerRuntimePutTps10 = initCache(outOfTimeSeconds);
        this.brokerRuntimePutLatency99 = initCache(outOfTimeSeconds);
        this.brokerRuntimePutLatency999 = initCache(outOfTimeSeconds);
        this.brokerRuntimeDispatchMaxBuffer = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap10toMore = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap5to10s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap4to5s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap3to4s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap2to3s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap1to2s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap500to1s = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap200to500ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap100to200ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap50to100ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap10to50ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap0to10ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePutMessageDistributeTimeMap0ms = initCache(outOfTimeSeconds);
        this.brokerRuntimePullThreadPoolQueueCapacity = initCache(outOfTimeSeconds);
        this.brokerRuntimeSendThreadPoolQueueCapacity = initCache(outOfTimeSeconds);
        this.brokerRuntimePullThreadPoolQueueSize = initCache(outOfTimeSeconds);
        this.brokerRuntimeQueryThreadPoolQueueSize = initCache(outOfTimeSeconds);
        this.brokerRuntimePullThreadPoolQueueHeadWaitTimeMills = initCache(outOfTimeSeconds);
        this.brokerRuntimeQueryThreadPoolQueueHeadWaitTimeMills = initCache(outOfTimeSeconds);
        this.brokerRuntimeSendThreadPoolQueueHeadWaitTimeMills = initCache(outOfTimeSeconds);
        this.brokerRuntimeCommitLogDirCapacityFree = initCache(outOfTimeSeconds);
        this.brokerRuntimeCommitLogDirCapacityTotal = initCache(outOfTimeSeconds);
        this.brokerRuntimeCommitLogMaxOffset = initCache(outOfTimeSeconds);
        this.brokerRuntimeCommitLogMinOffset = initCache(outOfTimeSeconds);
        this.brokerRuntimeRemainHowManyDataToFlush = initCache(outOfTimeSeconds);
    }