Method merge

src/sessions/shared.rs:23–32

(self, other: Self)

    /// Accumulate another pass's counters into this one.
    #[must_use]
    pub fn merge(self, other: Self) -> Self {
        Self {
            sessions_upserted: self
                .sessions_upserted
                .saturating_add(other.sessions_upserted),
            messages_upserted: self
                .messages_upserted
                .saturating_add(other.messages_upserted),
        }
    }
}

/// The incremental position persisted between ingestion runs.