Method reportFlushStats

packages/db/src/buffers/base-buffer.ts:253–266

* Subclasses call this from within onFlush to record what they actually * did. The base class includes these in the FlushObservation it emits.

(stats: {
    rowsProcessed?: number;
    phases?: FlushPhaseTimings;
  })

   * did. The base class includes these in the FlushObservation it emits.
   */
  protected reportFlushStats(stats: {
    rowsProcessed?: number;
    phases?: FlushPhaseTimings;
  }) {
    if (stats.rowsProcessed !== undefined) {
      this.inflightStats.rowsProcessed = stats.rowsProcessed;
    }
    if (stats.phases) {
      this.inflightStats.phases = {
        ...(this.inflightStats.phases ?? {}),
        ...stats.phases,
      };
    }
  }

  /**
   * Ground-truth size of the buffer (LLEN of the Redis list). O(1). The