pub(crate) async fn run(
config: RdioConfig,
pool: PgPool,
) -> Result<(), Box<dyn Error + Send + Sync>>Expand description
Runs the upload queue processor loop.
Polls the database for pending streams every
config.retry_interval_secs and uploads each to the Rdio Scanner
endpoint. Runs until cancelled.
§Errors
Returns an error only if building the shared reqwest::Client fails —
subsequent iteration errors (SQL, HTTP, multipart) are logged at warn
level and the loop keeps running so a brief outage does not freeze the
whole processor.