Module queue_manager 

Manages upload queue orchestration, retry persistence, and sync-index updates.

A configurable pool of async workers drains the upload queue in parallel. Failed tasks are moved to a retry queue with exponential back-off. The queue pauses automatically when environment policies (metered network, battery power, quiet hours) are active, and resumes when conditions clear.

Structs

BatchNotifyState 🔒

EnvironmentPolicy

FileTask

Represents a unit of work for the upload queue.

QueueManager

Functions

activate_batch_if_needed 🔒

add_to_album_with_retry 🔒

apply_active_state 🔒

apply_idle_state 🔒

batch_is_ready_to_notify 🔒

batch_notification_summary 🔒

check_batch_notification 🔒

clear_stale_batch_schedule 🔒

current_attempt_count 🔒

Get current sync attempt count for a path based on recent events history.

finalize_upload_progress 🔒

Finalize upload progress: update counters, detect queue idle, return batch ID if a summary notification should be scheduled.

handle_upload 🔒

Upload or reassociate a file, then ensure the resulting asset is present in the target album.

infer_album_name 🔒

Infer target album name from directory structure segment.

is_quiet_hour 🔒

Returns true if the current local clock hour falls inside the configured quiet window.

load_retries 🔒

Load historical list of failed tasks from retries cache.

record_upload_failure 🔒

Record state updates after a failed upload.

record_upload_success 🔒

Activate a batch tracking window if none is currently active. Record state updates after a successful upload.

resolve_album_id 🔒

Resolve the album ID from either an explicit task ID or by name lookup.

resolve_final_asset_id 🔒

save_retries 🔒

Persist current list of failed items to retries cache.

schedule_batch_notification 🔒

Spawn a debounced batch-notification task.

track_consecutive_failures 🔒

Track consecutive failures and fire a connectivity-lost notification after 3+.

unix_timestamp_now 🔒

Return current epoch timestamp in seconds.

upload_progress_callback 🔒

Helper to generate progress callback callbacks that update global transfer metrics.

wait_until_allowed 🔒

Pause worker processing loops until environment checks and manual pauses permit resume.