Struct TransferQueue 

pub struct TransferQueue { /* private fields */ }

Size-prioritized queue of blobs waiting for their download quota.

Shorter blobs are started first when they fit the remaining budget. This improves time-to-first-content for mixed workloads while leaving the quota accounting unchanged.

Implementations

impl TransferQueue

pub fn new() -> Self

pub fn enqueue(&self, item: PendingTransfer) -> bool

Add a transfer unless the same (namespace, hash) is already queued.

Returns true when the item was newly added.

pub fn pop_fitting(&self, budget: &TransferBudget) -> Option<PendingTransfer>

Remove and return the smallest item that fits the download budget.

pub fn remove_namespace(&self, namespace: NamespaceId)

Drop everything queued for a namespace (e.g. after leaving a folder).

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn pending_bytes(&self) -> u64

pub fn snapshot(&self) -> Vec<PendingTransfer>

Trait Implementations

impl Debug for TransferQueue

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

Formats the value using the given formatter.

impl Default for TransferQueue

fn default() -> Self

Returns the “default value” for a type.