Struct TransferQueue 

pub struct TransferQueue {
    registry: Arc<RwLock<TransferRegistry>>,
    semaphore: RwLock<Arc<Semaphore>>,
}

Concurrency-capped transfer queue wrapping TransferRegistry.

The [Semaphore] limits how many transfers run simultaneously. The semaphore is acquired inside the spawned task, so enqueue always returns immediately with a request_id.

When transfer_concurrency changes in settings, call rebuild_semaphore to replace the semaphore with a new one at the new width.

Fields

registry: Arc<RwLock<TransferRegistry>>

semaphore: RwLock<Arc<Semaphore>>

Implementations

impl TransferQueue

pub fn new(concurrency: u32) -> Self

Create a new queue with the given concurrency cap.

pub fn registry(&self) -> &RwLock<TransferRegistry>

Shared reference to the inner RwLock<TransferRegistry>.

pub fn rebuild_semaphore(&self, new_concurrency: u32)

Replace the semaphore with a new one at new_concurrency.

In-flight transfers hold their old permits until they finish; the new semaphore only affects newly spawned transfers.

pub fn current_semaphore(&self) -> Arc<Semaphore>

Acquire a clone of the current semaphore.

The returned Arc<Semaphore> is the one that was active at the moment of the call. Spawned tasks hold this arc; a rebuild_semaphore call does not invalidate existing permit holders.

pub fn registry_handle(&self) -> TransferRegistryHandle

Return a TransferRegistryHandle that shares the same underlying registry, suitable for passing to download_object / upload_object.

pub async fn list(&self, filter: Option<TransferFilter>) -> Vec<Transfer>

List transfers, optionally filtering by state.

filter = None is equivalent to TransferFilter::All.

pub async fn cancel(&self, id: &str) -> Result<(), AppError>

Cancel the transfer with id.

Trait Implementations

impl Default for TransferQueue

fn default() -> Self

Returns the “default value” for a type.