use crate::common::CommitVersion;
pub trait EvictionWatermark: Send + Sync + 'static {
fn watermark(&self) -> CommitVersion;
}
pub trait QueryWatermark: Send + Sync + 'static {
fn effective_gc_cutoff(&self) -> CommitVersion;
}
pub trait ConsumerPositions: Send + Sync + 'static {
fn min_position(&self) -> Option<CommitVersion>;
}
pub trait CheckpointFloor: Send + Sync + 'static {
fn floor(&self) -> Option<CommitVersion>;
}