apache / bifromq / 15485655791
65%

DEFAULT BRANCH: main
Ran
Jobs 1
Files 1068
Run time 5min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 63.254% (+0.5%) from 62.783%
15485655791

push

github

web-flow 
Replace license headers & resolve dependencies' license compatibility issues (#141)

* insert/replace license headers of all source files

* remove the dependency of jakarta.annotation.api

* switch to log4j to avoid license issue

6046 of 10796 branches covered (56.0%)

Branch coverage included in aggregate %.

23352 of 35680 relevant lines covered (65.45%)

2.95 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
97.06
 0.0% org/apache/bifromq/apiserver/http/handler/HeaderUtils.java
1
70.0
 0.0% org/apache/bifromq/apiserver/utils/TopicUtil.java
1
83.33
 0.0% org/apache/bifromq/basecluster/fd/FailureDetectorMath.java
1
93.33
 0.0% org/apache/bifromq/basecluster/IAgentHost.java
1
97.94
 0.0% org/apache/bifromq/basecluster/memberlist/agent/AgentMember.java
1
89.47
 0.0% org/apache/bifromq/basecluster/memberlist/HostAddressResolver.java
1
84.21
 0.0% org/apache/bifromq/basecluster/transport/AbstractTransport.java
1
90.32
 6.45% org/apache/bifromq/basecluster/util/RandomUtils.java
1
87.5
 0.0% org/apache/bifromq/basecrdt/core/api/EWFlagOperation.java
1
75.0
 0.0% org/apache/bifromq/basecrdt/core/api/IAWORSet.java
1
0.0
 0.0% org/apache/bifromq/basecrdt/core/api/ICCounter.java
1
0.0
 0.0% org/apache/bifromq/basecrdt/core/api/IDWFlag.java
1
0.0
 0.0% org/apache/bifromq/basecrdt/core/api/IEWFlag.java
1
0.0
 0.0% org/apache/bifromq/basecrdt/core/api/IMVReg.java
1
0.0
 0.0% org/apache/bifromq/basecrdt/core/api/IORMap.java
1
75.0
 0.0% org/apache/bifromq/basecrdt/core/api/IRWORSet.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/AWORSetInflater.java
1
94.74
 0.0% org/apache/bifromq/basecrdt/core/internal/CausalCRDT.java
1
94.64
 0.0% org/apache/bifromq/basecrdt/core/internal/CCounterCoalesceOperation.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/CCounterInflater.java
1
86.36
 0.0% org/apache/bifromq/basecrdt/core/internal/DotFunc.java
1
80.0
 0.0% org/apache/bifromq/basecrdt/core/internal/DotSet.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/DWFlagInflater.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/EWFlagInflater.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/MVRegInflater.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/ORMapInflater.java
1
75.0
 0.0% org/apache/bifromq/basecrdt/core/internal/ORMapUtil.java
1
83.33
 0.0% org/apache/bifromq/basecrdt/core/internal/RWORSetInflater.java
1
89.33
 0.14% org/apache/bifromq/basecrdt/service/CRDTService.java
1
60.0
 0.0% org/apache/bifromq/basecrdt/store/compressor/Compressor.java
1
93.75
 0.0% org/apache/bifromq/basecrdt/util/ProtoUtil.java
1
0.0
 0.0% org/apache/bifromq/basekv/balance/command/RangeCommand.java
1
0.0
 0.0% org/apache/bifromq/basekv/client/exception/BadRequestException.java
1
0.0
 0.0% org/apache/bifromq/basekv/client/exception/BadVersionException.java
1
0.0
 0.0% org/apache/bifromq/basekv/client/exception/InternalErrorException.java
1
0.0
 0.0% org/apache/bifromq/basekv/client/exception/TryLaterException.java
1
0.0
 0.0% org/apache/bifromq/basekv/client/IBaseKVStoreClient.java
1
92.31
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/Keys.java
1
88.89
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/NoopWriteStatsRecorder.java
1
0.0
 0.0% org/apache/bifromq/basekv/metaservice/IBaseKVMetaService.java
1
73.68
 0.0% org/apache/bifromq/basekv/metaservice/NameUtil.java
1
0.0
 0.0% org/apache/bifromq/basekv/RPCServerMetadataUtil.java
1
0.0
 0.0% org/apache/bifromq/basekv/server/IBaseKVStoreServer.java
1
91.67
 0.0% org/apache/bifromq/basekv/store/KVRangeMessenger.java
1
96.25
 2.5% org/apache/bifromq/basekv/store/range/KVRange.java
1
83.33
 0.0% org/apache/bifromq/basekv/store/range/KVRangeKeys.java
1
89.36
 0.0% org/apache/bifromq/basekv/store/util/KVUtil.java
1
92.86
 0.0% org/apache/bifromq/basekv/store/util/VerUtil.java
1
91.67
 0.0% org/apache/bifromq/basekv/store/wal/KVRangeWALKeys.java
1
96.88
 3.13% org/apache/bifromq/basekv/store/wal/KVRangeWALSubscription.java
1
98.75
 0.0% org/apache/bifromq/basekv/utils/DescriptorUtil.java
1
0.0
 0.0% org/apache/bifromq/basescheduler/IBatchCallBuilder.java
1
93.55
 0.0% org/apache/bifromq/basescheduler/MovingAverage.java
1
82.61
 0.0% org/apache/bifromq/base/util/CompletableFutureUtil.java
1
96.94
 0.0% org/apache/bifromq/deliverer/BatchDeliveryCall.java
1
0.0
 0.0% org/apache/bifromq/dist/client/IDistClient.java
1
0.0
 0.0% org/apache/bifromq/dist/client/scheduler/PubCallBatcherKey.java
1
88.76
 4.49% org/apache/bifromq/dist/trie/NTopicFilterTrieNode.java
1
93.55
 0.0% org/apache/bifromq/dist/trie/TopicTrieNode.java
1
50.0
 0.0% org/apache/bifromq/dist/worker/balance/RangeLeaderBalancerFactory.java
1
96.36
 0.0% org/apache/bifromq/dist/worker/cache/SubscriptionCache.java
1
96.05
 0.0% org/apache/bifromq/dist/worker/cache/TenantRouteMatcher.java
1
96.15
 0.0% org/apache/bifromq/dist/worker/Comparators.java
1
86.67
 0.0% org/apache/bifromq/dist/worker/schema/GroupMatching.java
1
93.75
 0.0% org/apache/bifromq/dist/worker/schema/NormalMatching.java
1
87.18
 0.0% org/apache/bifromq/inbox/server/InboxFetcherRegistry.java
1
75.0
 0.0% org/apache/bifromq/inbox/server/scheduler/InboxCommitScheduler.java
1
81.82
 0.0% org/apache/bifromq/inbox/server/scheduler/InboxFetchScheduler.java
1
50.0
 0.0% org/apache/bifromq/inbox/store/balance/RangeLeaderBalancerFactory.java
1
86.21
 0.0% org/apache/bifromq/inbox/store/InboxStoreCoProcFactory.java
1
93.88
 0.0% org/apache/bifromq/inbox/store/schema/KVSchemaUtil.java
1
0.0
 0.0% org/apache/bifromq/inbox/util/PipelineUtil.java
1
93.75
 0.0% org/apache/bifromq/metrics/TenantMeterCache.java
1
66.67
 0.0% org/apache/bifromq/mqtt/handler/condition/DirectMemPressureCondition.java
1
66.67
 0.0% org/apache/bifromq/mqtt/handler/condition/HeapMemPressureCondition.java
1
87.5
 0.0% org/apache/bifromq/mqtt/handler/condition/InboundResourceCondition.java
1
91.3
 0.0% org/apache/bifromq/mqtt/handler/MPSThrottler.java
1
91.55
 0.0% org/apache/bifromq/mqtt/handler/MQTTPacketFilter.java
1
85.71
 0.0% org/apache/bifromq/mqtt/handler/record/GoAway.java
1
97.78
 0.0% org/apache/bifromq/mqtt/handler/v3/MQTT3MessageBuilders.java
1
92.31
 0.0% org/apache/bifromq/mqtt/handler/v3/MQTT3MessageUtils.java
1
88.24
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5AuthReasonCode.java
1
93.88
 0.0% org/apache/bifromq/mqtt/handler/v5/SenderTopicAliasManager.java
1
90.48
 0.0% org/apache/bifromq/mqtt/handler/ws/MqttOverWSHandler.java
1
91.67
 0.0% org/apache/bifromq/mqtt/service/LocalSessionRegistry.java
1
0.0
 0.0% org/apache/bifromq/plugin/authprovider/MetricConstants.java
1
0.0
 0.0% org/apache/bifromq/plugin/clientbalancer/IClientBalancer.java
1
0.0
 0.0% org/apache/bifromq/plugin/clientbalancer/Redirection.java
1
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/IEventCollector.java
1
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ClientDisconnectEvent.java
1
95.24
 0.0% org/apache/bifromq/plugin/eventcollector/ThreadLocalEventPool.java
1
0.0
 0.0% org/apache/bifromq/plugin/resourcethrottler/IResourceThrottler.java
1
0.0
 0.0% org/apache/bifromq/plugin/settingprovider/ISettingProvider.java
1
0.0
 0.0% org/apache/bifromq/retain/client/IRetainClient.java
1
0.0
 0.0% org/apache/bifromq/retain/server/IRetainServer.java
1
92.31
 0.0% org/apache/bifromq/retain/server/scheduler/BatchRetainCallHelper.java
1
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/MatchCallBatcherKey.java
1
95.12
 0.0% org/apache/bifromq/retain/server/scheduler/MatchCallRangeRouter.java
1
50.0
 0.0% org/apache/bifromq/retain/store/balance/RangeLeaderBalancerFactory.java
1
92.86
 0.0% org/apache/bifromq/retain/store/schema/LevelHash.java
1
89.47
 0.0% org/apache/bifromq/retain/store/TenantRetainedSet.java
1
0.0
 0.0% org/apache/bifromq/sessiondict/client/ISessionDictClient.java
1
0.0
 0.0% org/apache/bifromq/sessiondict/client/type/OnlineCheckRequest.java
1
0.0
 0.0% org/apache/bifromq/sessiondict/server/ISessionDictServer.java
1
0.0
 0.0% org/apache/bifromq/starter/config/model/ExecutorConfig.java
1
0.0
 0.0% org/apache/bifromq/starter/config/model/InMemEngineConfig.java
1
0.0
 0.0% org/apache/bifromq/starter/config/model/SSLContextConfig.java
1
0.0
 0.0% org/apache/bifromq/starter/config/model/StorageEngineConfig.java
1
85.71
 0.0% org/apache/bifromq/sysprops/parser/BooleanParser.java
1
77.78
 0.0% org/apache/bifromq/sysprops/parser/DoubleParser.java
1
0.0
 0.0% org/apache/bifromq/util/index/TNode.java
1
0.0
 0.0% org/apache/bifromq/util/TopicConst.java
2
93.62
 0.0% org/apache/bifromq/apiserver/http/handler/GetServiceLandscapeHandler.java
2
88.0
 0.0% org/apache/bifromq/apiserver/http/handler/GetSessionInfoHandler.java
2
84.38
 0.0% org/apache/bifromq/apiserver/http/HTTPRouteMap.java
2
95.51
 0.0% org/apache/bifromq/basecluster/memberlist/AutoHealer.java
2
92.31
 0.0% org/apache/bifromq/basecluster/messenger/MessengerTransport.java
2
0.0
 0.0% org/apache/bifromq/basecrdt/core/exception/CRDTEngineException.java
2
96.32
 0.0% org/apache/bifromq/basecrdt/core/internal/EventHistoryUtil.java
2
93.1
 0.0% org/apache/bifromq/basecrdt/core/internal/ProtoUtils.java
2
66.67
 0.0% org/apache/bifromq/basecrdt/service/AgentUtil.java
2
0.0
 0.0% org/apache/bifromq/baseenv/IEnvProvider.java
2
78.95
 0.0% org/apache/bifromq/basehookloader/BaseHookLoader.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/BootstrapCommand.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/ChangeConfigCommand.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/MergeCommand.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/RecoveryCommand.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/SplitCommand.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/command/TransferLeadershipCommand.java
2
89.19
 0.0% org/apache/bifromq/basekv/balance/impl/RangeBootstrapBalancer.java
2
0.0
 0.0% org/apache/bifromq/basekv/balance/NoNeedBalance.java
2
77.78
 0.0% org/apache/bifromq/basekv/client/scheduler/BatchMutationCallBuilderFactory.java
2
58.33
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVEngine.java
2
91.89
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpace.java
2
92.86
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBCPableKVEngine.java
2
93.48
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceCompactionTrigger.java
2
71.43
 0.0% org/apache/bifromq/basekv/raft/exception/CompactionException.java
2
96.23
 0.0% org/apache/bifromq/basekv/raft/MetricMonitoredStateStore.java
2
91.89
 0.0% org/apache/bifromq/basekv/raft/PeerLogReplicator.java
2
91.84
 0.0% org/apache/bifromq/basekv/raft/PeerLogReplicatorStateSnapshotSyncing.java
2
95.24
 0.0% org/apache/bifromq/basekv/RPCBluePrint.java
2
71.43
 0.0% org/apache/bifromq/basekv/store/exception/KVRangeStoreException.java
2
50.0
 0.0% org/apache/bifromq/basescheduler/exception/BackPressureException.java
2
50.0
 0.0% org/apache/bifromq/basescheduler/exception/DropException.java
2
80.0
 0.0% org/apache/bifromq/deliverer/BatchDeliveryCallBuilderFactory.java
2
0.0
 0.0% org/apache/bifromq/deliverer/exception/DeliveryException.java
2
0.0
 0.0% org/apache/bifromq/dist/client/MatchResult.java
2
0.0
 0.0% org/apache/bifromq/dist/client/PubResult.java
2
0.0
 0.0% org/apache/bifromq/dist/client/UnmatchResult.java
2
81.25
 0.0% org/apache/bifromq/dist/server/DistServer.java
2
90.48
 0.0% org/apache/bifromq/dist/server/DistService.java
2
93.1
 0.0% org/apache/bifromq/dist/worker/DeliverExecutor.java
2
77.78
 0.0% org/apache/bifromq/dist/worker/schema/Matching.java
2
0.0
 0.0% org/apache/bifromq/dist/worker/spi/IDistWorkerBalancerFactory.java
2
0.0
 0.0% org/apache/bifromq/inbox/client/IInboxClient.java
2
91.67
 0.0% org/apache/bifromq/inbox/server/InboxServer.java
2
88.89
 8.33% org/apache/bifromq/inbox/server/scheduler/BatchInsertCall.java
2
0.0
 0.0% org/apache/bifromq/inbox/store/spi/IInboxStoreBalancerFactory.java
2
92.45
 0.0% org/apache/bifromq/inbox/util/InboxServiceUtil.java
2
62.5
 0.0% org/apache/bifromq/mqtt/handler/MQTTSessionIdUtil.java
2
91.67
 0.0% org/apache/bifromq/mqtt/handler/ProxyProtocolDetector.java
2
0.0
 0.0% org/apache/bifromq/mqtt/inbox/IMqttBrokerClient.java
2
75.0
 0.0% org/apache/bifromq/mqtt/inbox/util/DelivererKeyUtil.java
2
92.54
 0.0% org/apache/bifromq/mqtt/utils/MQTT3MessageSizer.java
2
0.0
 0.0% org/apache/bifromq/plugin/clientbalancer/DummyClientBalancer.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/ConnectTimeout.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/EnhancedAuthAbortByClient.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/IdentifierRejected.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/MalformedClientIdentifier.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/MalformedUserName.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/MalformedWillTopic.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/UnacceptedProtocolVer.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ByServer.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/InboxTransientError.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/OversizePacketDropped.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/DropReason.java
2
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS0Pushed.java
2
94.44
 0.0% org/apache/bifromq/plugin/settingprovider/MonitoredSettingProvider.java
2
87.5
 0.0% org/apache/bifromq/plugin/settingprovider/SettingProviderManager.java
2
87.88
 0.0% org/apache/bifromq/plugin/subbroker/SubBrokerManager.java
2
0.0
 0.0% org/apache/bifromq/retain/server/RetainServerBuilder.java
2
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/DeleteCallScheduler.java
2
94.92
 0.0% org/apache/bifromq/retain/store/RetainMatcher.java
2
0.0
 0.0% org/apache/bifromq/retain/store/spi/IRetainStoreBalancerFactory.java
2
86.21
 0.0% org/apache/bifromq/sessiondict/client/SessionRegistration.java
2
33.33
 0.0% org/apache/bifromq/sessiondict/server/ISessionRegistry.java
2
0.0
 0.0% org/apache/bifromq/sessiondict/server/SessionDictServerBuilder.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/ClusterConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/dict/SessionDictClientConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/dist/DistClientConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/inbox/InboxClientConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/MQTTBrokerClientConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/retain/RetainClientConfig.java
2
0.0
 0.0% org/apache/bifromq/starter/config/model/ServerSSLContextConfig.java
2
83.33
 0.0% org/apache/bifromq/starter/utils/ClusterDomainUtil.java
2
70.0
 0.0% org/apache/bifromq/sysprops/parser/LongParser.java
2
33.33
 0.0% org/apache/bifromq/test/RetryTransformer.java
3
28.57
 0.0% org/apache/bifromq/apiserver/ExceptionHandler.java
3
89.87
 0.0% org/apache/bifromq/apiserver/http/handler/KillHandler.java
3
92.52
 0.0% org/apache/bifromq/basecluster/AgentHost.java
3
95.16
 0.0% org/apache/bifromq/basecluster/memberlist/agent/Agent.java
3
70.37
 0.0% org/apache/bifromq/basecluster/transport/ProbeHandler.java
3
86.36
 0.0% org/apache/bifromq/basecrdt/core/api/CRDTURI.java
3
50.0
 0.0% org/apache/bifromq/basecrdt/store/MessagePayloadUtil.java
3
81.82
 0.0% org/apache/bifromq/baseenv/EnvProvider.java
3
80.99
 0.0% org/apache/bifromq/basekv/balance/impl/RangeSplitBalancer.java
3
87.72
 0.0% org/apache/bifromq/basekv/balance/impl/RedundantRangeRemovalBalancer.java
3
0.0
 0.0% org/apache/bifromq/basekv/client/BaseKVStoreClientBuilder.java
3
88.89
 0.0% org/apache/bifromq/basekv/client/KVRangeRouterUtil.java
3
69.23
 0.0% org/apache/bifromq/basekv/client/scheduler/BatchQueryCallBuilderFactory.java
3
0.0
 0.0% org/apache/bifromq/basekv/Constants.java
3
88.14
 0.0% org/apache/bifromq/basekv/localengine/AbstractKVEngine.java
3
0.0
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemWALableKVEngine.java
3
0.0
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemWALableKVSpace.java
3
72.73
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/AutoCleaner.java
3
75.0
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceReader.java
3
91.67
 0.0% org/apache/bifromq/basekv/raft/exception/DropProposalException.java
3
90.63
 0.0% org/apache/bifromq/basekv/raft/exception/LeaderTransferException.java
3
95.26
 0.0% org/apache/bifromq/basekv/raft/InMemoryStateStore.java
3
94.33
 0.0% org/apache/bifromq/basekv/raft/RaftConfigChanger.java
3
70.0
 0.0% org/apache/bifromq/basekv/store/range/hinter/QueryKVLoadBasedSplitHinter.java
3
30.0
 0.0% org/apache/bifromq/basekv/store/range/KVCheckpointReader.java
3
88.14
 0.0% org/apache/bifromq/basekv/store/range/KVRangeQueryLinearizer.java
3
85.0
 10.0% org/apache/bifromq/basekv/store/range/KVRangeWriter.java
3
78.95
 0.0% org/apache/bifromq/basekv/store/stats/StatsCollector.java
3
0.0
 0.0% org/apache/bifromq/dist/client/scheduler/PubCallScheduler.java
3
84.38
 0.0% org/apache/bifromq/inbox/client/InboxReader.java
3
63.64
 0.0% org/apache/bifromq/inbox/store/delay/ExpireInboxTask.java
3
65.22
 0.0% org/apache/bifromq/inbox/store/delay/SendLWTTask.java
3
86.27
 0.0% org/apache/bifromq/inbox/store/InboxStoreGCProcessor.java
3
88.16
 0.0% org/apache/bifromq/mqtt/handler/ConditionalSlowDownHandler.java
3
94.35
 0.0% org/apache/bifromq/mqtt/service/LocalDistService.java
3
89.74
 0.0% org/apache/bifromq/mqtt/session/MQTTSessionAuthProvider.java
3
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ByClient.java
3
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ReAuthFailed.java
3
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/WillDisted.java
3
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/session/MQTTSessionStart.java
3
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/session/MQTTSessionStop.java
3
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQDefaultPluginLoader.java
3
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQDevelopmentPluginLoader.java
3
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/MatchCallScheduler.java
3
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/RetainCallScheduler.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/dict/SessionDictServiceConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/dist/DistServiceConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/dist/DistWorkerClientConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/inbox/InboxServiceConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/inbox/InboxStoreClientConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/listener/TLSListenerConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/MQTTServiceConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/retain/RetainServiceConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/config/model/retain/RetainStoreClientConfig.java
3
0.0
 0.0% org/apache/bifromq/starter/module/ConfigModule.java
3
0.0
 0.0% org/apache/bifromq/starter/module/ServiceInjectorModule.java
3
0.0
 0.0% org/apache/bifromq/starter/module/SharedResourceProvider.java
4
87.5
 0.0% org/apache/bifromq/apiserver/http/handler/PubHandler.java
4
81.48
 0.0% org/apache/bifromq/basecluster/memberlist/agent/CRDTUtil.java
4
73.33
 0.0% org/apache/bifromq/basecluster/memberlist/CRDTUtil.java
4
93.1
 0.0% org/apache/bifromq/basecluster/messenger/Gossiper.java
4
0.0
 0.0% org/apache/bifromq/basecrdt/core/exception/CRDTCloseException.java
4
0.0
 0.0% org/apache/bifromq/basecrdt/core/exception/CRDTNotFoundException.java
4
66.67
 0.0% org/apache/bifromq/basecrdt/core/internal/CausalCRDTInflaterFactory.java
4
79.41
 0.0% org/apache/bifromq/basecrdt/core/internal/CCounter.java
4
73.33
 0.0% org/apache/bifromq/basecrdt/store/compressor/GzipCompressor.java
4
81.67
 0.0% org/apache/bifromq/basecrdt/store/PartialMesh.java
4
0.0
 0.0% org/apache/bifromq/baseenv/ZeroCopyParser.java
4
0.0
 0.0% org/apache/bifromq/basekv/balance/AwaitBalance.java
4
87.74
 0.0% org/apache/bifromq/basekv/balance/impl/UnreachableReplicaRemovalBalancer.java
4
90.24
 0.0% org/apache/bifromq/basekv/localengine/AbstractKVSpaceReader.java
4
0.0
 0.0% org/apache/bifromq/basekv/localengine/KVEngineException.java
4
89.47
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceIterator.java
4
76.92
 0.0% org/apache/bifromq/basekv/raft/exception/ClusterConfigChangeException.java
4
0.0
 0.0% org/apache/bifromq/basekv/raft/exception/InternalError.java
4
0.0
 0.0% org/apache/bifromq/basekv/raft/exception/SnapshotException.java
4
0.0
 0.0% org/apache/bifromq/basekv/server/BaseKVStoreServerBuilder.java
4
81.25
 0.0% org/apache/bifromq/basekv/store/KVRangeStoreStatsCollector.java
4
87.1
 0.0% org/apache/bifromq/basekv/store/range/AbstractKVRangeMetadata.java
4
61.54
 0.0% org/apache/bifromq/basekv/store/util/ExecutorServiceUtil.java
4
86.21
 0.0% org/apache/bifromq/basekv/store/wal/LogEntryIteratorPool.java
4
0.0
 0.0% org/apache/bifromq/basescheduler/exception/AbortException.java
4
0.0
 0.0% org/apache/bifromq/basescheduler/exception/BatcherUnavailableException.java
4
33.33
 0.0% org/apache/bifromq/base/util/exception/RetryTimeoutException.java
4
50.0
 0.0% org/apache/bifromq/deliverer/MessageDeliverer.java
4
91.67
 0.0% org/apache/bifromq/dist/server/handler/MatchReqHandler.java
4
90.2
 0.0% org/apache/bifromq/dist/server/handler/UnmatchReqHandler.java
4
83.95
 -4.94% org/apache/bifromq/dist/trie/STopicFilterTrieNode.java
4
92.71
 0.0% org/apache/bifromq/dist/worker/schema/KVSchemaUtil.java
4
46.15
 0.0% org/apache/bifromq/inbox/server/FetcherSignaler.java
4
91.53
 0.0% org/apache/bifromq/inbox/store/TenantsState.java
4
20.0
 0.0% org/apache/bifromq/metrics/ITenantMeter.java
4
70.83
 0.0% org/apache/bifromq/metrics/TenantMeter.java
4
82.93
 0.0% org/apache/bifromq/mqtt/handler/MQTTMessageDebounceHandler.java
4
88.89
 0.0% org/apache/bifromq/mqtt/handler/MQTTMessageHandler.java
4
50.0
 0.0% org/apache/bifromq/mqtt/handler/v5/MQTT5PersistentSessionHandler.java
4
50.0
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5PubCompReasonCode.java
4
50.0
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5PubRelReasonCode.java
4
91.34
 0.0% org/apache/bifromq/mqtt/service/LocalTopicRouter.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/accessctrl/AccessControlError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/accessctrl/SubActionDisallow.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/accessctrl/UnsubActionDisallow.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/ProtocolError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/BadPacket.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ClientChannelError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ExceedPubRate.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ExceedReceivingLimit.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/Idle.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/InvalidTopicFilter.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/InvalidTopic.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/Kicked.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/MalformedTopicFilter.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/MalformedTopic.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ProtocolViolation.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/Redirect.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ResourceThrottled.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/ServerBusy.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS0DistError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS1DistError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS1PubAckDropped.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS1PubAcked.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS2DistError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS2PubRecDropped.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/QoS2PubReced.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/WillDistError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/PingReq.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS0Dropped.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS1Dropped.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS1Pushed.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS2Dropped.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS2Pushed.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS2Received.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/retainhandling/MatchRetainError.java
4
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/OutOfTenantResource.java
4
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQJarPluginLoader.java
4
0.0
 0.0% org/apache/bifromq/sessiondict/client/type/OnlineCheckResult.java
4
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/listener/TCPListenerConfig.java
4
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/listener/WSListenerConfig.java
4
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/listener/WSSListenerConfig.java
4
0.0
 0.0% org/apache/bifromq/starter/config/model/RPCConfig.java
4
0.0
 0.0% org/apache/bifromq/test/RetryAnalyser.java
5
90.67
 0.0% org/apache/bifromq/basecluster/transport/UDPTransport.java
5
89.17
 0.0% org/apache/bifromq/basecrdt/core/internal/DotMap.java
5
45.45
 0.0% org/apache/bifromq/basecrdt/store/ReplicaIdGenerator.java
5
91.54
 0.0% org/apache/bifromq/basekv/balance/util/CommandUtil.java
5
84.09
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceIterator.java
5
59.26
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceReader.java
5
72.28
 0.0% org/apache/bifromq/basekv/server/MutatePipeline.java
5
0.0
 0.0% org/apache/bifromq/basekv/store/range/hinter/MutationKVLoadBasedSplitHinter.java
5
40.0
 0.0% org/apache/bifromq/basekv/store/range/KVRangeMetadataWriter.java
5
60.0
 0.0% org/apache/bifromq/basekv/store/range/LoadRecordableKVWriter.java
5
94.29
 0.95% org/apache/bifromq/basekv/store/wal/KVRangeWAL.java
5
66.67
 0.0% org/apache/bifromq/basescheduler/CallSchedulerFactory.java
5
72.0
 0.0% org/apache/bifromq/basescheduler/CapacityEstimatorFactory.java
5
0.0
 0.0% org/apache/bifromq/demo/plugin/DemoPluginContext.java
5
83.33
 0.0% org/apache/bifromq/demo/plugin/WebHookBasedResourceThrottler.java
5
30.0
 0.0% org/apache/bifromq/dist/server/scheduler/UnmatchCallScheduler.java
5
6.45
 0.0% org/apache/bifromq/dist/worker/balance/DistWorkerSplitBalancerFactory.java
5
0.0
 0.0% org/apache/bifromq/dist/worker/spi/SplitKey.java
5
79.71
 0.0% org/apache/bifromq/dist/worker/TenantsState.java
5
55.36
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchFetchCall.java
5
15.38
 0.0% org/apache/bifromq/inbox/store/balance/ReplicaCntBalancerFactory.java
5
91.56
 0.0% org/apache/bifromq/mqtt/handler/MQTTPreludeHandler.java
5
0.0
 0.0% org/apache/bifromq/plugin/BifroMQPluginContext.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/ClientEvent.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/ChannelClosedEvent.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/TooLargeSubscription.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/TooLargeUnsubscription.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/Discard.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS1Confirmed.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/QoS2Confirmed.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/retainhandling/RetainEvent.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/retainhandling/RetainMsgCleared.java
5
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/subhandling/UnsubAcked.java
5
0.0
 0.0% org/apache/bifromq/plugin/manager/ProvidedPackages.java
5
68.92
 0.0% org/apache/bifromq/plugin/settingprovider/Setting.java
5
30.0
 0.0% org/apache/bifromq/sessiondict/client/scheduler/OnlineCheckScheduler.java
5
0.0
 0.0% org/apache/bifromq/starter/config/model/api/APIServerConfig.java
5
0.0
 0.0% org/apache/bifromq/starter/config/model/dict/SessionDictServerConfig.java
5
0.0
 0.0% org/apache/bifromq/starter/config/model/dist/DistServerConfig.java
5
0.0
 0.0% org/apache/bifromq/starter/config/model/inbox/InboxServerConfig.java
5
0.0
 0.0% org/apache/bifromq/starter/config/model/retain/RetainServerConfig.java
5
0.0
 0.0% org/apache/bifromq/starter/module/ServiceInjector.java
5
75.76
 0.0% org/apache/bifromq/sysprops/BifroMQSysProp.java
5
0.0
 0.0% org/apache/bifromq/util/index/INode.java
5
0.0
 0.0% org/apache/bifromq/util/index/MainNode.java
6
81.82
 0.0% org/apache/bifromq/apiserver/APIServer.java
6
70.59
 0.0% org/apache/bifromq/apiserver/http/AnnotationUtil.java
6
79.55
 0.0% org/apache/bifromq/apiserver/http/handler/GetLoadRulesHandler.java
6
95.11
 0.92% org/apache/bifromq/basecrdt/core/internal/InMemReplicaStateLattice.java
6
80.23
 0.0% org/apache/bifromq/basecrdt/core/internal/VarLong.java
6
0.0
 0.0% org/apache/bifromq/basekv/balance/command/CommandType.java
6
0.0
 0.0% org/apache/bifromq/basekv/InProcStores.java
6
26.32
 0.0% org/apache/bifromq/basekv/localengine/KVEngineFactory.java
6
51.52
 0.0% org/apache/bifromq/basekv/localengine/metrics/KVSpaceOpMeters.java
6
79.49
 0.0% org/apache/bifromq/basekv/raft/PeerLogTracker.java
6
0.0
 0.0% org/apache/bifromq/basekv/server/BaseKVStoreServiceBuilder.java
6
91.06
 0.81% org/apache/bifromq/basekv/store/range/KVRangeRestorer.java
6
84.75
 0.0% org/apache/bifromq/basekv/store/wal/KVRangeWALStorageEngine.java
6
55.0
 0.0% org/apache/bifromq/basekv/utils/KVRangeIdUtil.java
6
72.92
 0.0% org/apache/bifromq/base/util/AsyncRetry.java
6
0.0
 0.0% org/apache/bifromq/base/util/exception/NeedRetryException.java
6
67.57
 0.0% org/apache/bifromq/demo/plugin/WebHookBasedSettingProvider.java
6
0.0
 0.0% org/apache/bifromq/dist/client/DistClientBuilder.java
6
0.0
 0.0% org/apache/bifromq/dist/RPCBluePrint.java
6
77.42
 0.0% org/apache/bifromq/dist/trie/MTopicFilterTrieNode.java
6
9.52
 0.0% org/apache/bifromq/dist/worker/balance/ReplicaCntBalancerFactory.java
6
73.21
 0.0% org/apache/bifromq/dist/worker/cache/TenantRouteCache.java
6
81.82
 0.0% org/apache/bifromq/dist/worker/DistWorkerCleaner.java
6
0.0
 0.0% org/apache/bifromq/inbox/client/InboxClientBuilder.java
6
85.22
 0.0% org/apache/bifromq/inbox/server/InboxWriter.java
6
7.5
 0.0% org/apache/bifromq/inbox/store/balance/RangeSplitBalancerFactory.java
6
69.23
 0.0% org/apache/bifromq/mqtt/handler/ChannelAttrs.java
6
38.89
 0.0% org/apache/bifromq/mqtt/handler/v5/IReAuthenticator.java
6
35.79
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5DisconnectReasonCode.java
6
40.0
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5PubAckReasonCode.java
6
48.57
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5PubRecReasonCode.java
6
54.55
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5SubAckReasonCode.java
6
41.38
 0.0% org/apache/bifromq/mqtt/handler/v5/reason/MQTT5UnsubAckReasonCode.java
6
0.0
 0.0% org/apache/bifromq/mqtt/inbox/MqttBrokerClientBuilder.java
6
0.0
 0.0% org/apache/bifromq/mqtt/inbox/RPCBluePrint.java
6
0.0
 0.0% org/apache/bifromq/plugin/BifroMQPluginDescriptor.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Disted.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/DistError.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/inboxservice/Overflowed.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/AuthError.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/ChannelError.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/NotAuthorizedClient.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/channelclosed/UnauthenticatedClient.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientdisconnect/NoPubPermission.java
6
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/subhandling/SubAcked.java
6
0.0
 0.0% org/apache/bifromq/plugin/resourcethrottler/TenantResourceType.java
6
0.0
 0.0% org/apache/bifromq/plugin/subbroker/TypeUtil.java
6
0.0
 0.0% org/apache/bifromq/retain/client/RetainClientBuilder.java
6
0.0
 0.0% org/apache/bifromq/retain/RPCBluePrint.java
6
87.3
 0.0% org/apache/bifromq/retain/server/scheduler/BatchMatchCallHelper.java
6
7.5
 0.0% org/apache/bifromq/retain/store/balance/RangeSplitBalancerFactory.java
6
9.52
 0.0% org/apache/bifromq/retain/store/balance/ReplicaCntBalancerFactory.java
6
94.05
 0.0% org/apache/bifromq/retain/store/RetainStoreCoProc.java
6
80.65
 0.0% org/apache/bifromq/retain/store/schema/KVSchemaUtil.java
6
0.0
 0.0% org/apache/bifromq/sessiondict/client/SessionDictClientBuilder.java
6
0.0
 0.0% org/apache/bifromq/sessiondict/RPCBluePrint.java
6
0.0
 0.0% org/apache/bifromq/sessiondict/server/SessionExistPipeline.java
6
78.57
 0.0% org/apache/bifromq/sessiondict/server/SessionRegister.java
6
0.0
 0.0% org/apache/bifromq/starter/config/model/mqtt/MQTTServerConfig.java
6
0.0
 0.0% org/apache/bifromq/starter/config/model/RocksDBEngineConfig.java
6
0.0
 0.0% org/apache/bifromq/starter/config/StandaloneConfig.java
6
0.0
 0.0% org/apache/bifromq/starter/metrics/netty/PooledByteBufAllocator.java
6
72.55
 0.0% org/apache/bifromq/starter/utils/ResourceUtil.java
6
0.0
 0.0% org/apache/bifromq/util/SizeUtil.java
7
81.48
 0.0% org/apache/bifromq/apiserver/http/HTTPRequestRouter.java
7
91.72
 0.0% org/apache/bifromq/basecluster/messenger/Messenger.java
7
81.25
 0.0% org/apache/bifromq/basecrdt/core/internal/ORMap.java
7
75.56
 0.0% org/apache/bifromq/basecrdt/core/util/LatticeIndexUtil.java
7
85.11
 0.0% org/apache/bifromq/basecrdt/service/CRDTCluster.java
7
0.0
 0.0% org/apache/bifromq/basekv/balance/StoreBalancer.java
7
0.0
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceCheckpoint.java
7
78.57
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVEngineIterator.java
7
86.89
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVEngine.java
7
95.55
 0.0% org/apache/bifromq/basekv/raft/RaftNodeStateCandidate.java
7
74.29
 0.0% org/apache/bifromq/basekv/server/AgentHostStoreMessenger.java
7
82.81
 0.0% org/apache/bifromq/basescheduler/BatchCallScheduler.java
7
89.47
 0.0% org/apache/bifromq/base/util/AsyncRunner.java
7
0.0
 0.0% org/apache/bifromq/demo/plugin/DemoResourceThrottler.java
7
0.0
 0.0% org/apache/bifromq/dist/client/scheduler/BatchPubCallBuilderFactory.java
7
0.0
 0.0% org/apache/bifromq/inbox/record/TenantInboxInstance.java
7
0.0
 0.0% org/apache/bifromq/inbox/RPCBluePrint.java
7
0.0
 0.0% org/apache/bifromq/inbox/store/spi/SplitKey.java
7
42.86
 0.0% org/apache/bifromq/mqtt/MQTTBrokerBuilder.java
7
70.73
 0.0% org/apache/bifromq/mqtt/utils/IMQTTMessageSizer.java
7
37.93
 0.0% org/apache/bifromq/plugin/authprovider/DevOnlyAuthProvider.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Delivered.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/DeliverError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/DeliverNoInbox.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Matched.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/MatchError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Subscribed.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/SubscribeError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Unmatched.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/UnmatchError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/Unsubscribed.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/distservice/UnsubscribeError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/accessctrl/PubActionDisallow.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/clientconnected/ClientConnected.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/retainhandling/MsgRetainedError.java
7
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/retainhandling/MsgRetained.java
7
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQPluginClassLoader.java
7
72.22
 0.0% org/apache/bifromq/plugin/subbroker/NoInboxSubBroker.java
7
0.0
 0.0% org/apache/bifromq/sessiondict/SessionRegisterKeyUtil.java
7
30.0
 0.0% org/apache/bifromq/test/RetryListener.java
7
0.0
 0.0% org/apache/bifromq/util/index/Branch.java
8
72.34
 0.0% org/apache/bifromq/apiserver/http/handler/RetainHandler.java
8
75.61
 0.0% org/apache/bifromq/apiserver/http/handler/SetLoadRulesHandler.java
8
11.54
 0.0% org/apache/bifromq/apiserver/http/handler/UnsetTrafficRulesHandler.java
8
92.65
 0.0% org/apache/bifromq/basecluster/memberlist/HostMemberList.java
8
38.46
 21.79% org/apache/bifromq/basecrdt/util/Formatter.java
8
71.15
 0.0% org/apache/bifromq/basekv/balance/impl/RangeLeaderBalancer.java
8
33.33
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemCPableKVSpace.java
8
88.89
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceWriterHelper.java
8
85.53
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceWriterHelper.java
8
94.47
 3.52% org/apache/bifromq/basekv/raft/RaftNodeState.java
8
88.68
 0.0% org/apache/bifromq/basekv/store/range/KVRangeQueryRunner.java
8
71.74
 0.0% org/apache/bifromq/basekv/store/util/ProcessUtil.java
8
0.0
 0.0% org/apache/bifromq/demo/plugin/EventLogger.java
8
0.0
 0.0% org/apache/bifromq/demo/plugin/util/VariableUtil.java
8
76.67
 0.0% org/apache/bifromq/dist/server/scheduler/BatchMatchCall.java
8
75.86
 0.0% org/apache/bifromq/dist/server/scheduler/BatchUnmatchCall.java
8
62.26
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchCheckSubCall.java
8
55.0
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchExistCall.java
8
66.67
 0.0% org/apache/bifromq/plugin/eventcollector/EventCollectorManager.java
8
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/Event.java
8
80.7
 0.0% org/apache/bifromq/plugin/resourcethrottler/ResourceThrottlerManager.java
8
62.5
 0.0% org/apache/bifromq/retain/store/gc/RetainStoreGCProcessor.java
8
0.0
 0.0% org/apache/bifromq/retain/store/spi/SplitKey.java
8
85.91
 0.0% org/apache/bifromq/sessiondict/server/SessionRegistry.java
8
0.0
 0.0% org/apache/bifromq/starter/module/SharedResourcesHolder.java
8
0.0
 0.0% org/apache/bifromq/starter/utils/ConfigFileUtil.java
9
10.0
 0.0% org/apache/bifromq/apiserver/http/handler/GetStoreRangesHandler.java
9
70.15
 0.0% org/apache/bifromq/basekv/client/scheduler/BatchQueryCall.java
9
82.46
 0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceWriter.java
9
83.75
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVEngineConfigurator.java
9
42.11
 0.0% org/apache/bifromq/basekv/store/range/LoadRecordableKVReader.java
9
83.44
 -3.07% org/apache/bifromq/basescheduler/Batcher.java
9
80.25
 0.0% org/apache/bifromq/dist/worker/DeliverExecutorGroup.java
9
0.0
 0.0% org/apache/bifromq/inbox/client/InboxDeliverPipeline.java
9
83.57
 0.0% org/apache/bifromq/mqtt/utils/AuthUtil.java
9
74.51
 0.0% org/apache/bifromq/plugin/clientbalancer/ClientBalancerManager.java
9
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQPluginFactory.java
9
69.23
 0.0% org/apache/bifromq/plugin/subbroker/MonitoredSubBroker.java
9
0.0
 0.0% org/apache/bifromq/retain/server/RetainServer.java
9
0.0
 0.0% org/apache/bifromq/sessiondict/server/SessionDictServer.java
9
0.0
 0.0% org/apache/bifromq/starter/metrics/netty/PooledByteBufAllocatorMetric.java
9
63.93
 0.0% org/apache/bifromq/util/UTF8Util.java
10
13.33
 0.0% org/apache/bifromq/apiserver/http/handler/GetClusterHandler.java
10
8.57
 0.0% org/apache/bifromq/apiserver/http/handler/GetTrafficRulesHandler.java
10
10.34
 0.0% org/apache/bifromq/apiserver/http/handler/SetServerGroupTagsHandler.java
10
7.89
 0.0% org/apache/bifromq/apiserver/http/handler/SetTrafficRulesHandler.java
10
80.49
 0.0% org/apache/bifromq/basecluster/memberlist/AutoSeeder.java
10
92.21
 0.0% org/apache/bifromq/basecrdt/core/internal/CausalCRDTInflater.java
10
87.45
 0.0% org/apache/bifromq/basecrdt/core/internal/ORMapCoalesceOperation.java
10
74.36
 0.0% org/apache/bifromq/basekv/client/scheduler/BatchMutationCall.java
10
76.27
 0.0% org/apache/bifromq/basekv/store/range/hinter/LoadRecordWindow.java
10
88.0
 0.57% org/apache/bifromq/basekv/store/range/KVRangeDumpSession.java
10
62.65
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchAttachCall.java
10
82.91
 0.0% org/apache/bifromq/plugin/authprovider/AuthProviderManager.java
10
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQPluginManager.java
11
35.09
 0.0% org/apache/bifromq/apiserver/http/handler/GetStoreLandscapeHandler.java
11
82.05
 -0.59% org/apache/bifromq/basecrdt/store/CRDTStore.java
11
67.74
 -9.68% org/apache/bifromq/basehlc/HLC.java
11
76.79
 0.0% org/apache/bifromq/basekv/client/KVRangeSetting.java
11
97.86
 0.0% org/apache/bifromq/basekv/raft/BasicStateStoreTest.java
11
84.07
 0.0% org/apache/bifromq/basekv/server/QueryPipeline.java
11
80.42
 0.0% org/apache/bifromq/dist/worker/balance/DistWorkerSplitBalancer.java
11
0.0
 0.0% org/apache/bifromq/metrics/TenantGauges.java
11
0.0
 0.0% org/apache/bifromq/sessiondict/client/scheduler/BatchSessionExistCall.java
11
0.0
 0.0% org/apache/bifromq/starter/config/model/dist/DistWorkerConfig.java
11
0.0
 0.0% org/apache/bifromq/starter/config/model/inbox/InboxStoreConfig.java
11
0.0
 0.0% org/apache/bifromq/starter/config/model/retain/RetainStoreConfig.java
11
0.0
 0.0% org/apache/bifromq/starter/module/APIServerModule.java
11
0.0
 0.0% org/apache/bifromq/starter/module/SessionDictServiceModule.java
11
0.0
 0.0% org/apache/bifromq/util/BSUtil.java
12
0.0
 0.0% org/apache/bifromq/basekv/client/ManagedMutationPipeline.java
12
0.0
 0.0% org/apache/bifromq/basekv/client/ManagedQueryPipeline.java
12
33.33
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceSnapshot.java
12
61.97
 0.0% org/apache/bifromq/dist/server/DistResponsePipeline.java
12
61.36
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchDetachCall.java
12
60.47
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchSubCall.java
12
60.0
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchUnsubCall.java
12
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQExtensionFactory.java
12
56.76
 0.0% org/apache/bifromq/plugin/settingprovider/CacheOptions.java
12
0.0
 0.0% org/apache/bifromq/starter/module/ExecutorsModule.java
13
85.76
 0.0% org/apache/bifromq/basekv/utils/BoundaryUtil.java
13
0.0
 0.0% org/apache/bifromq/demo/plugin/DemoSettingProvider.java
13
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/disthandling/DistEvent.java
13
0.0
 0.0% org/apache/bifromq/starter/module/RPCClientSSLContextModule.java
14
87.06
 0.0% org/apache/bifromq/basecluster/transport/TCPTransport.java
14
65.31
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceCheckpoint.java
14
42.03
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBWALableKVSpace.java
14
81.95
 0.0% org/apache/bifromq/basekv/store/range/KVRangeMetricManager.java
14
0.0
 0.0% org/apache/bifromq/demo/plugin/DemoAuthProvider.java
14
0.0
 0.0% org/apache/bifromq/demo/plugin/DemoPlugin.java
14
73.53
 0.0% org/apache/bifromq/dist/worker/DistWorker.java
14
78.75
 0.0% org/apache/bifromq/inbox/store/delay/DelayTaskRunner.java
14
76.47
 0.0% org/apache/bifromq/inbox/store/InboxStore.java
14
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/EventType.java
14
0.0
 0.0% org/apache/bifromq/starter/module/EngineConfUtil.java
14
0.0
 0.0% org/apache/bifromq/starter/module/MQTTServiceModule.java
14
0.0
 0.0% org/apache/bifromq/starter/module/SSLUtil.java
15
88.16
 0.0% org/apache/bifromq/basecluster/fd/FailureDetector.java
15
0.0
 0.0% org/apache/bifromq/basekv/store/range/LoadRecordableKVIterator.java
15
91.33
 0.0% org/apache/bifromq/dist/worker/DistWorkerCoProc.java
15
0.0
 0.0% org/apache/bifromq/plugin/manager/BifroMQExtensionFinder.java
15
84.82
 0.0% org/apache/bifromq/util/TopicUtil.java
16
84.21
 2.11% org/apache/bifromq/basecrdt/store/AntiEntropy.java
16
49.43
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchDeleteCall.java
16
47.56
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchSendLWTCall.java
16
12.5
 0.0% org/apache/bifromq/mqtt/service/LocalSessionBrokerService.java
16
0.0
 0.0% org/apache/bifromq/starter/config/model/BalancerOptions.java
17
69.51
 0.0% org/apache/bifromq/basekv/store/range/hinter/KVLoadBasedSplitHinter.java
17
0.0
 0.0% org/apache/bifromq/starter/module/RPCServerBuilderModule.java
18
84.12
 1.29% org/apache/bifromq/mqtt/handler/MQTTTransientSessionHandler.java
18
63.85
 0.0% org/apache/bifromq/retain/server/RetainService.java
19
0.0
 0.0% org/apache/bifromq/apiserver/http/handler/JSONUtils.java
19
54.41
 0.0% org/apache/bifromq/demo/plugin/WebHookBasedAuthProvider.java
19
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/BatchRetainCall.java
19
0.0
 0.0% org/apache/bifromq/starter/module/DistServiceModule.java
19
0.0
 0.0% org/apache/bifromq/starter/module/InboxServiceModule.java
19
0.0
 0.0% org/apache/bifromq/util/index/CNode.java
20
80.92
 0.0% org/apache/bifromq/basekv/balance/impl/ReplicaCntBalancer.java
20
85.66
 0.0% org/apache/bifromq/basekv/metaservice/BaseKVClusterMetadataManager.java
20
67.35
 0.0% org/apache/bifromq/inbox/client/InboxClient.java
20
4.29
 0.0% org/apache/bifromq/inbox/server/TenantGCRunner.java
20
63.64
 0.0% org/apache/bifromq/retain/store/RetainStore.java
20
0.0
 0.0% org/apache/bifromq/starter/module/RetainServiceModule.java
21
0.0
 0.0% org/apache/bifromq/plugin/authprovider/IAuthProvider.java
22
73.26
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceWriter.java
22
0.0
 0.0% org/apache/bifromq/dist/client/scheduler/BatchPubCall.java
22
0.0
 0.0% org/apache/bifromq/mqtt/inbox/MqttBrokerClient.java
22
0.0
 0.0% org/apache/bifromq/retain/client/RetainClient.java
22
0.0
 0.0% org/apache/bifromq/starter/ServiceBootstrapper.java
23
82.96
 0.0% org/apache/bifromq/basekv/raft/RaftNode.java
23
60.42
 0.0% org/apache/bifromq/dist/worker/hinter/FanoutSplitHinter.java
23
38.1
 0.0% org/apache/bifromq/mqtt/ConnListenerBuilder.java
23
0.0
 0.0% org/apache/bifromq/mqtt/handler/SendBufferCapacityHinter.java
23
0.0
 0.0% org/apache/bifromq/plugin/eventcollector/mqttbroker/pushhandling/PushEvent.java
23
59.8
 0.0% org/apache/bifromq/sessiondict/client/SessionDictClient.java
24
61.36
 0.0% org/apache/bifromq/basekv/balance/impl/RuleBasedPlacementBalancer.java
24
64.15
 0.0% org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java
24
0.0
 0.0% org/apache/bifromq/basekv/server/BaseKVStoreServer.java
24
58.65
 0.0% org/apache/bifromq/inbox/server/InboxFetchPipeline.java
25
69.72
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBCPableKVSpace.java
25
70.99
 2.29% org/apache/bifromq/dist/trie/TopicFilterIterator.java
25
0.0
 0.0% org/apache/bifromq/inbox/server/scheduler/BatchCommitCall.java
26
61.64
 0.0% org/apache/bifromq/mqtt/handler/v5/MQTT5MessageUtils.java
27
0.0
 0.0% org/apache/bifromq/dist/client/DistClient.java
27
29.66
 0.0% org/apache/bifromq/mqtt/handler/v5/ReAuthenticator.java
28
58.6
 0.0% org/apache/bifromq/mqtt/MQTTBroker.java
28
0.0
 0.0% org/apache/bifromq/retain/server/scheduler/BatchMatchCall.java
29
86.82
 0.0% org/apache/bifromq/basekv/store/wal/KVRangeWALStore.java
29
27.47
 0.0% org/apache/bifromq/mqtt/utils/MQTTMessageTrimmer.java
30
0.0
 0.0% org/apache/bifromq/starter/config/StandaloneConfigConsolidator.java
31
0.0
 0.0% org/apache/bifromq/baseenv/NettyEnv.java
31
80.85
 0.0% org/apache/bifromq/mqtt/handler/v3/MQTT3ConnectHandler.java
31
0.0
 0.0% org/apache/bifromq/plugin/BifroMQPlugin.java
32
82.76
 0.0% org/apache/bifromq/mqtt/handler/v3/MQTT3ProtocolHelper.java
33
61.38
 0.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpace.java
33
85.38
 -0.31% org/apache/bifromq/basekv/raft/RaftNodeStateLeader.java
34
79.78
 1.12% org/apache/bifromq/basecluster/memberlist/AutoDropper.java
34
54.5
 0.0% org/apache/bifromq/dist/server/scheduler/BatchDistServerCall.java
34
0.0
 0.0% org/apache/bifromq/sessiondict/server/SessionDictService.java
35
0.0
 0.0% org/apache/bifromq/starter/module/PluginModule.java
40
82.45
 -0.51% org/apache/bifromq/basekv/raft/RaftNodeStateFollower.java
42
0.0
 0.0% org/apache/bifromq/baseenv/MemUsage.java
42
78.4
 -0.05% org/apache/bifromq/basekv/balance/KVStoreBalanceController.java
42
74.57
 0.0% org/apache/bifromq/mqtt/handler/MQTTPersistentSessionHandler.java
46
0.0
 0.0% org/apache/bifromq/basekv/server/BaseKVStoreService.java
46
63.46
 0.0% org/apache/bifromq/mqtt/utils/MQTT5MessageSizer.java
47
76.51
 0.0% org/apache/bifromq/mqtt/handler/MQTTConnectHandler.java
47
76.06
 0.0% org/apache/bifromq/mqtt/handler/v5/MQTT5MessageBuilders.java
49
78.46
 0.0% org/apache/bifromq/basekv/store/KVRangeStore.java
49
0.0
 0.0% org/apache/bifromq/starter/StandaloneStarter.java
59
55.88
 0.0% org/apache/bifromq/inbox/server/InboxService.java
69
0.0
 0.0% org/apache/bifromq/util/index/TopicLevelTrie.java
91
0.0
 0.0% org/apache/bifromq/starter/module/CoreServiceModule.java
92
57.88
 0.0% org/apache/bifromq/mqtt/handler/v5/MQTT5ConnectHandler.java
97
0.0
 0.0% org/apache/bifromq/basekv/client/BaseKVStoreClient.java
101
80.5
 0.0% org/apache/bifromq/inbox/store/InboxStoreCoProc.java
125
55.66
 0.0% org/apache/bifromq/mqtt/handler/v5/MQTT5ProtocolHelper.java
146
75.74
 1.84% org/apache/bifromq/basekv/store/range/KVRangeFSM.java
152
74.66
 -0.68% org/apache/bifromq/mqtt/handler/MQTTSessionHandler.java
Jobs
ID Job ID Ran Files Coverage
1 15485655791.1 1068
63.25
 GitHub Action Run
Source Files on build 15485655791