Struct TransferCheckpoint 

pub struct TransferCheckpoint {
    pub session_id: String,
    pub digest: String,
    pub total_size: u64,
    pub offset: u64,
    pub chunks_completed: u64,
    pub partial_sha256: Vec<u8>,
    pub upload_session_url: Option<String>,
}

Checkpoint state for a streaming transfer in progress.

Serializable so it can be persisted to disk and recovered after crash.

Fields

session_id: String

Unique transfer session identifier.

digest: String

Content digest being transferred.

total_size: u64

Total blob size in bytes.

offset: u64

Bytes successfully transferred and checkpointed.

chunks_completed: u64

Number of chunks completed.

partial_sha256: Vec<u8>

Serialized SHA256 hasher state (intermediate hash of bytes seen so far). We store the hash-so-far as bytes; on resume we cannot truly resume SHA256 mid-stream without re-reading, so this tracks verified offset.

upload_session_url: Option<String>

Upload session URL (for OCI chunked upload resume).

Implementations

impl TransferCheckpoint

pub fn new(session_id: &str, digest: &str, total_size: u64) -> Self

Create a new checkpoint for a fresh transfer.

pub fn is_complete(&self) -> bool

Whether the transfer is complete.

pub fn progress(&self) -> f64

Progress as a fraction (0.0 to 1.0).

pub fn remaining(&self) -> u64

Bytes remaining.

Trait Implementations

impl Clone for TransferCheckpoint

fn clone(&self) -> TransferCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransferCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TransferCheckpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TransferCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.