Struct UploadState 

pub struct UploadState {
    pub name: String,
    pub uuid: String,
    pub buffer: BytesMut,
    pub last_activity: Instant,
}

State of an in-flight blob upload.

Stored per upload UUID. Chunk bytes are accumulated in buffer until the final PUT arrives and the client-declared digest is compared against a recompute over the buffer.

Fields

name: String

Repository name the upload belongs to.

uuid: String

Upload UUID generated by crate::registry::RegistryMeta::start_upload.

buffer: BytesMut

Accumulated bytes.

last_activity: Instant

Wall-clock instant of the last activity on this session (creation or the most recent appended chunk). Used by the registry to evict idle sessions after a TTL (R2-7).

Implementations

impl UploadState

pub fn new(name: impl Into<String>, uuid: impl Into<String>) -> Self

Build a new empty upload state.

pub fn offset(&self) -> u64

Current byte offset (= number of bytes buffered so far).

pub fn append(&mut self, chunk: &Bytes) -> u64

Append a chunk, returning the new offset. Refreshes the last-activity timestamp so an actively-progressing upload is not swept by the idle-session TTL.

pub fn is_idle_for(&self, now: Instant, ttl: Duration) -> bool

True when this session has been idle (no creation/append activity) for at least ttl measured against now.

pub fn take_bytes(&mut self) -> Bytes

Take the accumulated bytes, leaving the buffer empty.

Trait Implementations

impl Clone for UploadState

fn clone(&self) -> UploadState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UploadState

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

Formats the value using the given formatter.