reifydb_subscription/state.rs
1// SPDX-License-Identifier: AGPL-3.0-or-later
2// Copyright (c) 2025 ReifyDB
3
4//! Consumption state tracking for subscriptions.
5
6use reifydb_core::{encoded::key::EncodedKey, interface::catalog::id::SubscriptionId};
7
8/// Consumption state for a single subscription.
9#[derive(Debug, Clone)]
10pub struct ConsumptionState {
11 /// The database subscription ID being consumed
12 pub db_subscription_id: SubscriptionId,
13 /// The last row key that was successfully consumed and deleted
14 /// Used as a cursor for incremental polling
15 pub last_consumed_key: Option<EncodedKey>,
16}