pub async fn acquire_lock( ct: &CancellationToken, storage: &Arc<dyn Storage>, key: &str, ) -> Result<LockGuard>
Acquire a distributed lock and register it as owned by this process .