pub async fn upload_loop( pool: &ConnectionPool, chunker: Arc<Mutex<&mut Chunker>>, remote: &Remote, namespace_id: i32, local_registry_updated_rx: Receiver<IndexerUpdateEvent>, ) -> Result<(), SyncError>