Merge pull request #289 from ably/feature/REA-2258

Add new batching and conflation processed stats
ably · Jan 22, 2025 · dfc989d · dfc989d
2 parents 338272e + 7b62855
commit dfc989d
Show file tree

Hide file tree

Showing 2 changed files with 50 additions and 6 deletions.
diff --git a/json-schemas/src/account-stats.json b/json-schemas/src/account-stats.json
@@ -479,19 +479,16 @@
           "inclusiveMinimum": 0,
           "description": "Total outbound realtime state message count (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.billableCount": {
           "type": "number",
           "inclusiveMinimum": 0,
           "description": "Total billable outbound realtime state message count (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.data": {
           "type": "number",
           "inclusiveMinimum": 0,
           "description": "Total outbound realtime state message size (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.uncompressedData": {
           "type": "number",
           "inclusiveMinimum": 0,
@@ -1097,6 +1094,31 @@
           "inclusiveMinimum": 0,
           "description": "Total number of messages on channels where delta generation was attempted but where a delta was not successfully generated, so Ably just broadcasted the original, see https://ably.com/docs/channels/options/deltas."
         },
+        "messages.processed.batching.simple.inboundMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages aggregated into batches with the 'simple' batching policy."
+        },
+        "messages.processed.batching.simple.generatedBatches": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of batches generated by the 'simple' batching policy."
+        },
+        "messages.processed.batching.conflating.inboundMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages aggregated into batches with the 'conflating' batching policy."
+        },
+        "messages.processed.batching.conflating.generatedBatches": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of batches generated by the 'conflating' batching policy."
+        },
+        "messages.processed.batching.conflating.discardedMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages discarded by the 'conflating' batching policy."
+        },
         "connections.all.peak": {
           "type": "number",
           "inclusiveMinimum": 0,

diff --git a/json-schemas/src/app-stats.json b/json-schemas/src/app-stats.json
@@ -483,19 +483,16 @@
           "inclusiveMinimum": 0,
           "description": "Total outbound realtime state message count (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.billableCount": {
           "type": "number",
           "inclusiveMinimum": 0,
           "description": "Total billable outbound realtime state message count (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.data": {
           "type": "number",
           "inclusiveMinimum": 0,
           "description": "Total outbound realtime state message size (sent from the Ably service to clients)."
         },
-
         "messages.outbound.realtime.state.uncompressedData": {
           "type": "number",
           "inclusiveMinimum": 0,
@@ -1101,6 +1098,31 @@
           "inclusiveMinimum": 0,
           "description": "Total number of messages on channels where delta generation was attempted but where a delta was not successfully generated, so Ably just broadcasted the original, see https://ably.com/docs/channels/options/deltas."
         },
+        "messages.processed.batching.simple.inboundMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages aggregated into batches with the 'simple' batching policy."
+        },
+        "messages.processed.batching.simple.generatedBatches": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of batches generated by the 'simple' batching policy."
+        },
+        "messages.processed.batching.conflating.inboundMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages aggregated into batches with the 'conflating' batching policy."
+        },
+        "messages.processed.batching.conflating.generatedBatches": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of batches generated by the 'conflating' batching policy."
+        },
+        "messages.processed.batching.conflating.discardedMessages": {
+          "type": "number",
+          "inclusiveMinimum": 0,
+          "description": "Total number of messages discarded by the 'conflating' batching policy."
+        },
         "connections.all.peak": {
           "type": "number",
           "inclusiveMinimum": 0,