Struct TransferRegistry 

pub struct TransferRegistry {
    transfers: HashMap<String, Transfer>,
    cancel_tokens: HashMap<String, CancelToken>,
}

In-memory registry of active and recently-completed transfers.

Thread-safe via Arc<RwLock<TransferRegistry>>. Commands register a transfer, spawn the work, and the work task calls back via update.

Fields

transfers: HashMap<String, Transfer>

cancel_tokens: HashMap<String, CancelToken>

Implementations

impl TransferRegistry

pub fn new() -> Self

pub fn register(&mut self, transfer: Transfer) -> (String, Receiver<()>)

Register a new transfer and return its id (UUID v4).

Returns (id, cancel_receiver) — the caller spawns the task with the receiver so it can detect a cancel signal.

pub fn update<F>(&mut self, id: &str, mutator: F) -> Result<(), AppError>

where F: FnOnce(&mut Transfer),

Apply a mutator closure to the transfer with id.

Returns AppError::NotFound when the id is unknown.

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

Send the cancellation signal to the transfer with id.

The cancel token is consumed on first call; subsequent calls on the same id return Ok(()) (idempotent).

pub fn list(&self, profile_filter: Option<&ProfileId>) -> Vec<Transfer>

Return transfers, optionally filtered by profile_id.

None → all transfers.

pub fn get(&self, id: &str) -> Option<&Transfer>

Retrieve a single transfer by id.

Trait Implementations

impl Default for TransferRegistry

fn default() -> Self

Returns the “default value” for a type.