Struct UploadQueue 

pub struct UploadQueue { /* private fields */ }

An asynchronous upload queue that batches host-to-device transfers.

Implementations

impl UploadQueue

pub fn new() -> Self

Create a new upload queue with default configuration.

pub fn with_config(config: UploadQueueConfig) -> Self

Create a new upload queue with the given configuration.

pub fn enqueue( &mut self, data: Vec<u8>, target: UploadTarget, priority: UploadPriority, ) -> Option<UploadId>

Enqueue an upload request. Returns the UploadId if successful, or None if the queue is full.

pub fn flush(&mut self) -> Vec<UploadId>

Flush a batch of uploads, simulating the transfer to GPU. Returns the IDs of requests that were processed.

pub fn cancel(&mut self, id: UploadId) -> bool

Cancel a pending upload by ID.

pub fn pending_count(&self) -> usize

Return the number of pending requests.

pub fn queued_bytes(&self) -> usize

Return the total queued bytes.

pub fn is_empty(&self) -> bool

Check if the queue is empty.

pub fn request_state(&self, id: UploadId) -> Option<UploadState>

Return the state of a request by ID.

pub fn stats(&self) -> UploadQueueStats

Return statistics about the queue.

pub fn clear(&mut self)

Clear all pending requests (marking them cancelled).

pub fn peek_next(&self) -> Option<&UploadRequest>

Peek at the next request that would be processed.

Trait Implementations

impl Default for UploadQueue

fn default() -> Self

Returns the “default value” for a type.