fixup! add storage version garbage collector

This commit is contained in:
Haowei Cai 2020-11-12 16:34:27 -08:00
parent f675dac440
commit 1d5a8f8f24

View File

@ -231,6 +231,7 @@ func (c *Controller) enqueueStorageVersion(obj *apiserverinternalv1alpha1.Storag
if err != nil || lease == nil || lease.Labels == nil ||
lease.Labels[controlplane.IdentityLeaseComponentLabelKey] != controlplane.KubeAPIServer {
// we cannot find a corresponding identity lease in cache, enqueue the storageversion
klog.V(4).Infof("Observed storage version %s with invalid apiserver entry", obj.Name)
c.storageVersionQueue.Add(obj.Name)
return
}