Struct CheckpointMetadata

pub struct CheckpointMetadata<'a> {
    shard_id: &'a str,
    sequence_number: &'a str,
}

Metadata associated with a checkpoint operation

This struct provides access to checkpoint metadata through reference-based accessors, providing context about the checkpoint operation such as shard ID and sequence number.

Examples

use go_zoom_kinesis::processor::CheckpointMetadata;

fn validate_checkpoint(metadata: &CheckpointMetadata) {
    println!("Checkpointing shard {} at sequence {}",
        metadata.shard_id(),
        metadata.sequence_number()
    );

    // Perform checkpoint validation
    if metadata.sequence_number().starts_with("49579") {
        println!("Checkpoint at expected sequence range");
    }
}

Fields

shard_id: &'a str

ID of the shard being checkpointed

sequence_number: &'a str

Sequence number being checkpointed

Implementations

impl CheckpointMetadata<'_>

pub fn shard_id(&self) -> &str

Gets the ID of the shard being checkpointed

pub fn sequence_number(&self) -> &str

Gets the sequence number being checkpointed

Trait Implementations

impl<'a> Clone for CheckpointMetadata<'a>

fn clone(&self) -> CheckpointMetadata<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for CheckpointMetadata<'a>

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

Formats the value using the given formatter.