Struct ActiveTransfer 

pub struct ActiveTransfer {
    pub id: Uuid,
    pub class: QoSClass,
    pub bytes_total: usize,
    pub bytes_sent: Atomic<usize>,
    pub can_pause: bool,
    pub is_paused: Atomic<bool>,
    pub started_at: Instant,
    pub paused_at: RwLock<Option<Instant>>,
}

An active data transfer being tracked by the preemption controller

Fields

id: Uuid

Unique transfer identifier

class: QoSClass

QoS class of this transfer

bytes_total: usize

Total bytes to transfer

bytes_sent: Atomic<usize>

Bytes sent so far

can_pause: bool

Whether this transfer can be paused

is_paused: Atomic<bool>

Whether this transfer is currently paused

started_at: Instant

When the transfer started

paused_at: RwLock<Option<Instant>>

When the transfer was paused (if applicable)

Implementations

impl ActiveTransfer

pub fn new( class: QoSClass, bytes_total: usize, can_pause: bool, ) -> ActiveTransfer

Create a new active transfer

pub fn progress(&self) -> f64

Get progress as percentage (0.0 - 1.0)

pub fn bytes_remaining(&self) -> usize

Get remaining bytes to transfer

pub fn record_sent(&self, bytes: usize)

Record bytes sent

pub fn is_complete(&self) -> bool

Check if transfer is complete

pub fn can_be_preempted_by(&self, class: QoSClass) -> bool

Check if this transfer can be preempted by the given class

pub async fn pause(&self)

Pause this transfer

pub async fn resume(&self)

Resume this transfer

pub async fn paused_duration(&self) -> Option<Duration>

Get time spent paused (if currently paused)

Trait Implementations

impl Debug for ActiveTransfer

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

Formats the value using the given formatter.