Struct IncrementalCheckpointMetadata 

pub struct IncrementalCheckpointMetadata {
    pub id: u64,
    pub epoch: u64,
    pub timestamp: u64,
    pub wal_position: u64,
    pub source_offsets: HashMap<String, u64>,
    pub watermark: Option<i64>,
    pub size_bytes: u64,
    pub key_count: u64,
    pub is_incremental: bool,
    pub parent_id: Option<u64>,
    pub sst_files: Vec<String>,
}

Metadata for an incremental checkpoint.

Fields

id: u64

Unique checkpoint ID.

epoch: u64

Epoch at which the checkpoint was taken.

timestamp: u64

Unix timestamp when checkpoint was created.

wal_position: u64

WAL position at checkpoint time.

source_offsets: HashMap<String, u64>

Source offsets for exactly-once semantics.

watermark: Option<i64>

Watermark at checkpoint time.

size_bytes: u64

Size of the checkpoint in bytes.

key_count: u64

Number of keys in the checkpoint.

is_incremental: bool

Whether this is an incremental checkpoint.

parent_id: Option<u64>

Parent checkpoint ID (for incremental).

sst_files: Vec<String>

SSTable files included (for incremental, relative paths).

Implementations

impl IncrementalCheckpointMetadata

pub fn new(id: u64, epoch: u64) -> Self

Creates a new checkpoint metadata instance.

pub fn checkpoint_path(&self, base_dir: &Path) -> PathBuf

Returns the path to this checkpoint’s directory.

pub fn to_json(&self) -> Result<String, IncrementalCheckpointError>

Serializes metadata to JSON.

Errors

Returns an error if serialization fails.

pub fn from_json(json: &str) -> Result<Self, IncrementalCheckpointError>

Deserializes metadata from JSON.

Errors

Returns an error if deserialization fails.

Trait Implementations

impl Clone for IncrementalCheckpointMetadata

fn clone(&self) -> IncrementalCheckpointMetadata

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IncrementalCheckpointMetadata

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IncrementalCheckpointMetadata

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for IncrementalCheckpointMetadata

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.