Rename status counters for clarity and add total_received

Rename total_accepted → total_buffered (only counts reports that
passed the pause check), add total_received (every 202 response),
and update total_dropped to received − forwarded so the full
picture is visible via /status.

Author: AlexVanderbist

CLAUDE.md

@@ -70,7 +70,9 @@ k6 run loadtest/loadtest.js
 kill %1
 ```
 
-`--test` mode uses `NullUpstream` — payloads are accepted and flushed through the full pipeline but no HTTP leaves the process. Stats (accepted, forwarded, buffered, memory) are printed every 5 seconds.
+`--test` mode uses `NullUpstream` — payloads are accepted and flushed through the full pipeline but no HTTP leaves the process. Stats (received, buffered, forwarded, pending, memory) are printed every 5 seconds.
+
+The `/status` endpoint exposes lifetime counters: `total_received` (all 202 responses), `total_buffered` (passed the pause check), `total_forwarded` (sent upstream successfully), and `total_dropped` (received minus forwarded).
 
 The k6 script ramps from 1→200 VUs over 80 seconds, posting realistic error payloads to `/v1/errors`. Pass `DAEMON_URL` and `API_KEY` env vars to customize.
 

loadtest/README.md

@@ -25,7 +25,7 @@ k6 run loadtest/loadtest.js
 ## What `--test` mode does
 
 - Replaces the real upstream with a null upstream that instantly returns `204`
-- Prints periodic stats to stdout: accepted/forwarded counts, buffer size, memory usage
+- Prints periodic stats to stdout: received/buffered/forwarded counts, pending buffer size, memory usage
 - The full buffer and flush pipeline still runs — the only difference is no HTTP leaves the process
 
 ## Goals

src/Ingest.php

@@ -26,7 +26,9 @@ class Ingest
 
     protected QuotaState $quotaState;
 
-    protected int $totalAccepted = 0;
+    protected int $totalReceived = 0;
+
+    protected int $totalBuffered = 0;
 
     protected int $totalForwarded = 0;
 
@@ -64,6 +66,8 @@ public function isShuttingDown(): bool
      */
     public function accept(string $apiKey, string $type, array $payload): void
     {
+        $this->totalReceived++;
+
         if ($this->shuttingDown) {
             return;
         }
@@ -74,7 +78,7 @@ public function accept(string $apiKey, string $type, array $payload): void
             return;
         }
 
-        $this->totalAccepted++;
+        $this->totalBuffered++;
 
         $this->output->debug('payload accepted', [
             'api_key' => $apiKey,
@@ -146,7 +150,13 @@ public function shutdown(?callable $onDrained = null): void
     }
 
     /**
-     * @return array{keys: array<string, array<string, array{buffered: int, paused: bool, retry_after: string|null, last_429_reason: string|null}>>|object}
+     * @return array{
+     *     total_received: int,
+     *     total_buffered: int,
+     *     total_forwarded: int,
+     *     total_dropped: int,
+     *     keys: array<string, array<string, array{buffered: int, paused: bool, retry_after: string|null, last_429_reason: string|null}>>|object
+     * }
      */
     public function status(): array
     {
@@ -156,7 +166,12 @@ public function status(): array
             ...$this->quotaState->keys(),
         ]);
 
-        $status = [];
+        $status = [
+            'total_received' => $this->totalReceived,
+            'total_buffered' => $this->totalBuffered,
+            'total_forwarded' => $this->totalForwarded,
+            'total_dropped' => $this->totalReceived - $this->totalForwarded,
+        ];
 
         foreach ($keys as $apiKey) {
             foreach (QuotaState::ENTITY_TYPES as $type) {
@@ -171,35 +186,41 @@ public function status(): array
             }
         }
 
-        return $status === [] ? ['keys' => new \stdClass] : $status;
+        if (! isset($status['keys'])) {
+            $status['keys'] = new \stdClass;
+        }
+
+        return $status;
     }
 
     /**
      * @return array{
-     *     accepted: int,
-     *     forwarded: int,
+     *     received: int,
      *     buffered: int,
-     *     buffered_bytes: int,
+     *     forwarded: int,
+     *     pending: int,
+     *     pending_bytes: int,
      *     in_flight: int
      * }
      */
     public function stats(): array
     {
-        $buffered = 0;
-        $bufferedBytes = 0;
+        $pending = 0;
+        $pendingBytes = 0;
 
         foreach ($this->buffers as $typedBuffers) {
             foreach ($typedBuffers as $buffer) {
-                $buffered += $buffer->count();
-                $bufferedBytes += $buffer->bufferedBytes();
+                $pending += $buffer->count();
+                $pendingBytes += $buffer->bufferedBytes();
             }
         }
 
         return [
-            'accepted' => $this->totalAccepted,
+            'received' => $this->totalReceived,
+            'buffered' => $this->totalBuffered,
             'forwarded' => $this->totalForwarded,
-            'buffered' => $buffered,
-            'buffered_bytes' => $bufferedBytes,
+            'pending' => $pending,
+            'pending_bytes' => $pendingBytes,
             'in_flight' => $this->inFlight,
         ];
     }

src/daemon.php

@@ -94,10 +94,11 @@
     $loop->addPeriodicTimer(5.0, function () use ($ingest, $output): void {
         $stats = $ingest->stats();
         $output->info('stats', [
-            'accepted' => $stats['accepted'],
-            'forwarded' => $stats['forwarded'],
+            'received' => $stats['received'],
             'buffered' => $stats['buffered'],
-            'buffered_bytes' => $stats['buffered_bytes'],
+            'forwarded' => $stats['forwarded'],
+            'pending' => $stats['pending'],
+            'pending_bytes' => $stats['pending_bytes'],
             'in_flight' => $stats['in_flight'],
             'memory_mb' => round(memory_get_usage(true) / 1024 / 1024, 2),
         ]);

tests/Feature/ServerTest.php

@@ -19,7 +19,7 @@
     expect($healthResponse->getStatusCode())->toBe(200)
         ->and(json_decode((string) $healthResponse->getBody(), true))->toBe(['status' => 'ok'])
         ->and($statusResponse->getStatusCode())->toBe(200)
-        ->and(json_decode((string) $statusResponse->getBody(), true))->toBe(['keys' => []]);
+        ->and(json_decode((string) $statusResponse->getBody(), true))->toBe(['total_received' => 0, 'total_buffered' => 0, 'total_forwarded' => 0, 'total_dropped' => 0, 'keys' => []]);
 });
 
 it('validates incoming requests', function () {
@@ -144,7 +144,7 @@
         ->and($testResponse->getHeaderLine('Content-Type'))->toContain('text/plain')
         ->and($testResponse->getHeaderLine('Retry-After'))->toBe('60')
         ->and((string) $testResponse->getBody())->toBe('Trace quota exceeded')
-        ->and(json_decode((string) $statusResponse->getBody(), true))->toBe(['keys' => []]);
+        ->and(json_decode((string) $statusResponse->getBody(), true))->toBe(['total_received' => 0, 'total_buffered' => 0, 'total_forwarded' => 0, 'total_dropped' => 0, 'keys' => []]);
 });
 
 it('returns validation and rejection responses for test payloads', function () {