• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

apache / bifromq / 19283226694
65%

Build:
DEFAULT BRANCH: main
Ran 12 Nov 2025 02:15AM UTC
Jobs 1
Files 1164
Run time 2min
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

12 Nov 2025 01:17AM UTC coverage: 64.927% (+0.4%) from 64.497%
19283226694

push

github

web-flow
Update merge protocol & various improvements for production stability (#188)

Base-KV improvements:
Loosens the merge prerequisite on config alignment, enhances the RedundantRangeRemovalBalancer to detect and purge zombie ranges, refactors the local engine for pluggability, and rolls out multiple optimizations—snapshot session reuse, obsolete snapshot filtering, leaner installation flow, lower split/merge memory pressure, faster distributed range lookup, RocksDB internal metrics toggles, redefined WAL compaction thresholds, improved WAL read path, and better default local-engine settings—alongside pluggable split hinters.

Inbox service optimizations:
Cuts read/write overhead in InboxStoreCoProc and accelerates BatchInsertRequest marshalling.

Multi-tenancy enhancements:
Adds tenant-level observability metrics and introduces a tenant-level switch to publish will messages during shutdown.

Bug fixes:
Resolves a NoSuchElementException when parsing AgentMetadata from CRDT and eliminates task duplication in BatchQueryCall.

7182 of 12533 branches covered (57.3%)

Branch coverage included in aggregate %.

27420 of 40761 relevant lines covered (67.27%)

3.02 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
95.51
-1.12% org/apache/bifromq/basecluster/memberlist/AutoHealer.java
1
93.73
-0.19% org/apache/bifromq/basecluster/memberlist/HostMemberList.java
1
82.69
-1.44% org/apache/bifromq/basecrdt/store/AntiEntropy.java
1
0.0
0.0% org/apache/bifromq/basekv/balance/command/CommandType.java
1
0.0
0.0% org/apache/bifromq/basekv/client/IBaseKVStoreClient.java
1
0.0
-100.0% org/apache/bifromq/basekv/localengine/KVSpaceDescriptor.java
1
91.67
-8.33% org/apache/bifromq/basekv/localengine/metrics/GeneralKVSpaceMetric.java
1
96.23
0.0% org/apache/bifromq/basekv/raft/MetricMonitoredStateStore.java
1
83.03
1.66% org/apache/bifromq/basekv/raft/RaftNodeStateFollower.java
1
0.0
-100.0% org/apache/bifromq/basekv/store/api/IKVRangeCoProcFactory.java
1
87.5
17.5% org/apache/bifromq/basekv/store/range/hinter/QueryKVLoadBasedSplitHinter.java
1
97.25
2.75% org/apache/bifromq/deliverer/BatchDeliveryCall.java
1
92.63
-1.99% org/apache/bifromq/dist/worker/cache/TenantRouteMatcher.java
1
94.78
10.94% org/apache/bifromq/mqtt/handler/AdaptiveReceiveQuota.java
1
94.15
-0.03% org/apache/bifromq/retain/store/RetainStoreCoProc.java
2
90.0
0.53% org/apache/bifromq/basecluster/messenger/MessengerTransport.java
2
58.33
0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVEngine.java
2
0.0
0.0% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceCheckpoint.java
2
77.78
-22.22% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBWALableKVEngine.java
2
95.36
0.1% org/apache/bifromq/basekv/raft/InMemoryStateStore.java
2
95.35
0.11% org/apache/bifromq/basekv/RPCBluePrint.java
2
81.25
0.0% org/apache/bifromq/basekv/store/KVRangeStoreStatsCollector.java
2
84.0
-16.0% org/apache/bifromq/basekv/store/option/KVRangeStoreOptions.java
2
0.0
0.0% org/apache/bifromq/basekv/store/range/LoadRecordableKVIterator.java
2
76.32
-2.63% org/apache/bifromq/basekv/store/stats/StatsCollector.java
2
92.42
3.54% org/apache/bifromq/inbox/server/scheduler/BatchInsertCall.java
2
91.34
-3.15% org/apache/bifromq/mqtt/service/LocalTopicRouter.java
3
82.14
0.66% org/apache/bifromq/basecluster/memberlist/agent/CRDTUtil.java
3
0.0
0.0% org/apache/bifromq/baseenv/ZeroCopyParser.java
3
95.49
1.16% org/apache/bifromq/basekv/raft/RaftConfigChanger.java
3
0.0
-100.0% org/apache/bifromq/basekv/store/api/IKVRangeCoProc.java
3
88.52
0.39% org/apache/bifromq/basekv/store/range/KVRangeQueryLinearizer.java
3
91.49
2.66% org/apache/bifromq/basekv/store/range/KVRangeRestorer.java
3
96.25
0.2% org/apache/bifromq/basekv/store/wal/KVRangeWALSubscription.java
3
90.91
-5.39% org/apache/bifromq/inbox/server/InboxWriterPipeline.java
4
90.67
0.0% org/apache/bifromq/basecluster/transport/UDPTransport.java
4
0.0
0.0% org/apache/bifromq/basekv/balance/command/MergeCommand.java
4
0.0
0.0% org/apache/bifromq/basekv/localengine/memory/InMemWALableKVEngine.java
4
88.57
-4.29% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBCPableKVEngine.java
4
88.64
25.89% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceCheckpoint.java
4
88.64
-11.36% org/apache/bifromq/basekv/localengine/SyncContext.java
4
83.58
0.77% org/apache/bifromq/basescheduler/BatchCallScheduler.java
4
93.72
4.71% org/apache/bifromq/basescheduler/Batcher.java
4
87.88
-12.12% org/apache/bifromq/dist/server/scheduler/TenantRangeLookupCache.java
4
79.69
0.32% org/apache/bifromq/mqtt/handler/MQTTMessageHandler.java
4
69.7
0.18% org/apache/bifromq/plugin/settingprovider/Setting.java
4
82.46
-17.54% org/apache/bifromq/retain/store/TenantsStats.java
5
0.0
0.0% org/apache/bifromq/basekv/store/range/hinter/MutationKVLoadBasedSplitHinter.java
5
92.59
8.47% org/apache/bifromq/basekv/store/range/KVRange.java
6
94.37
2.85% org/apache/bifromq/basekv/balance/impl/RedundantRangeRemovalBalancer.java
6
70.77
-4.99% org/apache/bifromq/basekv/client/scheduler/BatchQueryCall.java
6
84.69
16.42% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceWriterHelper.java
6
64.71
-7.29% org/apache/bifromq/basescheduler/CapacityEstimatorFactory.java
6
68.13
-3.3% org/apache/bifromq/dist/trie/TopicFilterIterator.java
6
53.85
-32.82% org/apache/bifromq/inbox/store/InboxStoreCoProcFactory.java
7
0.0
-100.0% org/apache/bifromq/basekv/client/scheduler/QueryCallScheduler.java
7
80.0
-2.46% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceWriter.java
7
87.3
0.42% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVEngine.java
7
92.52
-0.81% org/apache/bifromq/basekv/store/wal/KVRangeWAL.java
7
85.62
1.5% org/apache/bifromq/basekv/store/wal/KVRangeWALStore.java
7
72.84
0.0% org/apache/bifromq/inbox/server/InboxWriter.java
7
76.27
0.0% org/apache/bifromq/inbox/store/InboxStore.java
8
91.88
0.16% org/apache/bifromq/basecluster/messenger/Messenger.java
8
85.26
0.16% org/apache/bifromq/basecrdt/service/CRDTCluster.java
8
0.0
-69.23% org/apache/bifromq/basekv/client/scheduler/BatchQueryCallBuilderFactory.java
8
88.82
-0.07% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceWriterHelper.java
8
0.0
-88.89% org/apache/bifromq/basekv/localengine/rocksdb/NoopWriteStatsRecorder.java
8
86.55
0.59% org/apache/bifromq/basekv/store/range/KVRangeQueryRunner.java
8
82.46
7.46% org/apache/bifromq/basekv/store/range/KVRangeWriter.java
8
53.85
11.74% org/apache/bifromq/basekv/store/range/LoadRecordableKVReader.java
8
90.99
-0.16% org/apache/bifromq/dist/worker/DistWorkerCoProc.java
9
0.0
0.0% org/apache/bifromq/basekv/client/ManagedQueryPipeline.java
9
0.0
-26.32% org/apache/bifromq/basekv/localengine/KVEngineFactory.java
9
83.0
-7.0% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceIterator.java
9
76.09
1.8% org/apache/bifromq/basekv/server/AgentHostStoreMessenger.java
10
97.86
0.0% org/apache/bifromq/basekv/raft/BasicStateStoreTest.java
10
73.27
0.0% org/apache/bifromq/dist/worker/DistWorker.java
10
0.0
-100.0% org/apache/bifromq/dist/worker/hinter/RecordEstimation.java
11
76.36
7.13% org/apache/bifromq/dist/server/DistResponsePipeline.java
12
0.0
0.0% org/apache/bifromq/basekv/client/ManagedMutationPipeline.java
12
0.0
0.0% org/apache/bifromq/basekv/localengine/memory/InMemWALableKVSpace.java
12
81.16
1.79% org/apache/bifromq/basekv/server/QueryPipeline.java
12
82.61
0.65% org/apache/bifromq/basekv/store/range/KVRangeMetricManager.java
12
58.33
1.12% org/apache/bifromq/inbox/server/InboxFetchPipeline.java
13
72.88
-11.21% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceIterator.java
13
86.81
4.51% org/apache/bifromq/basekv/store/range/KVRangeDumpSession.java
14
66.67
-12.64% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVEngineIterator.java
15
67.74
-5.17% org/apache/bifromq/base/util/AsyncRetry.java
16
40.0
-19.26% org/apache/bifromq/basekv/localengine/memory/InMemKVSpaceReader.java
16
67.92
-4.52% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpaceWriter.java
16
69.14
-0.38% org/apache/bifromq/basekv/store/range/hinter/KVLoadBasedSplitHinter.java
16
77.16
2.99% org/apache/bifromq/dist/worker/TenantsStats.java
17
65.79
32.46% org/apache/bifromq/basekv/localengine/memory/InMemCPableKVSpace.java
17
0.0
-51.52% org/apache/bifromq/basekv/localengine/metrics/KVSpaceOpMeters.java
18
75.76
0.27% org/apache/bifromq/inbox/store/TenantsStats.java
18
81.15
-0.02% org/apache/bifromq/mqtt/handler/MQTTTransientSessionHandler.java
18
0.0
0.0% org/apache/bifromq/starter/module/InboxServiceModule.java
18
0.0
0.0% org/apache/bifromq/starter/module/RetainServiceModule.java
19
0.0
0.0% org/apache/bifromq/starter/module/DistServiceModule.java
20
74.44
-7.58% org/apache/bifromq/basecluster/memberlist/AutoDropper.java
22
0.0
0.0% org/apache/bifromq/dist/client/scheduler/BatchPubCall.java
24
47.06
5.03% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBWALableKVSpace.java
25
84.52
0.69% org/apache/bifromq/basekv/raft/RaftNodeStateLeader.java
27
83.8
0.28% org/apache/bifromq/basekv/raft/RaftNode.java
29
57.29
-4.08% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBKVSpace.java
33
33.33
-58.56% org/apache/bifromq/basekv/localengine/memory/InMemKVSpace.java
39
0.0
-90.24% org/apache/bifromq/basekv/localengine/AbstractKVSpaceReader.java
39
57.5
0.07% org/apache/bifromq/mqtt/handler/v5/MQTT5ProtocolHelper.java
52
77.41
-2.99% org/apache/bifromq/basekv/balance/KVStoreBalanceController.java
52
76.99
7.26% org/apache/bifromq/basekv/localengine/rocksdb/RocksDBCPableKVSpace.java
62
40.14
-24.01% org/apache/bifromq/basekv/localengine/metrics/KVSpaceMeters.java
62
0.0
0.0% org/apache/bifromq/basekv/server/BaseKVStoreService.java
63
0.0
-88.14% org/apache/bifromq/basekv/localengine/AbstractKVEngine.java
73
73.98
2.46% org/apache/bifromq/mqtt/handler/MQTTPersistentSessionHandler.java
91
0.0
-60.42% org/apache/bifromq/dist/worker/hinter/FanoutSplitHinter.java
96
60.31
2.43% org/apache/bifromq/mqtt/handler/v5/MQTT5ConnectHandler.java
103
73.88
-4.37% org/apache/bifromq/basekv/store/KVRangeStore.java
109
0.0
0.0% org/apache/bifromq/basekv/client/BaseKVStoreClient.java
118
0.0
0.0% org/apache/bifromq/starter/config/StandaloneConfigConsolidator.java
126
81.54
1.29% org/apache/bifromq/mqtt/handler/MQTTSessionHandler.java
143
80.58
-1.59% org/apache/bifromq/inbox/store/InboxStoreCoProc.java
175
83.16
9.62% org/apache/bifromq/basekv/store/range/KVRangeFSM.java
Jobs
ID Job ID Ran Files Coverage
1 19283226694.1 12 Nov 2025 02:15AM UTC 1164
64.93
GitHub Action Run
Source Files on build 19283226694
  • Tree
  • List 1164
  • Changed 190
  • Source Changed 0
  • Coverage Changed 190
Coverage ∆ File Lines Relevant Covered Missed Hits/Line Branch Hits Branch Misses
  • Back to Repo
  • Github Actions Build #19283226694
  • 2b342e98 on github
  • Prev Build on main (#18609927891)
  • Next Build on main (#19522019796)
  • Delete
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc