Struct ConditionalPut 

pub struct ConditionalPut {
    pub partition_id: u32,
    pub expected_epoch: u64,
    pub writer_node: NodeId,
}

Conditional PUT parameters for object storage epoch fencing.

Used when writing checkpoint data to S3/GCS/Azure to ensure that only the current epoch owner can write.

Fields

partition_id: u32

The partition being checkpointed.

expected_epoch: u64

The epoch that must match for the write to succeed.

writer_node: NodeId

The node that is writing.

Implementations

impl ConditionalPut

pub const fn new( partition_id: u32, expected_epoch: u64, writer_node: NodeId, ) -> Self

Create conditional PUT parameters.

pub fn to_metadata(&self) -> Vec<(String, String)>

Convert to HTTP header metadata for S3 conditional PUT.

Trait Implementations

impl Clone for ConditionalPut

fn clone(&self) -> ConditionalPut

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConditionalPut

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

Formats the value using the given formatter.