mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-26 05:03:09 +00:00
Merge pull request #19239 from markturansky/fixup_pv_controllers
Auto commit by PR queue bot
This commit is contained in:
commit
6a5ea5ec04
@ -156,6 +156,7 @@ func (binder *PersistentVolumeClaimBinder) updateClaim(oldObj, newObj interface{
|
|||||||
newClaim, ok := newObj.(*api.PersistentVolumeClaim)
|
newClaim, ok := newObj.(*api.PersistentVolumeClaim)
|
||||||
if !ok {
|
if !ok {
|
||||||
glog.Errorf("Expected PersistentVolumeClaim but handler received %+v", newObj)
|
glog.Errorf("Expected PersistentVolumeClaim but handler received %+v", newObj)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
if err := syncClaim(binder.volumeIndex, binder.client, newClaim); err != nil {
|
if err := syncClaim(binder.volumeIndex, binder.client, newClaim); err != nil {
|
||||||
glog.Errorf("PVClaimBinder could not update claim %s: %+v", newClaim.Name, err)
|
glog.Errorf("PVClaimBinder could not update claim %s: %+v", newClaim.Name, err)
|
||||||
|
@ -77,6 +77,7 @@ func NewPersistentVolumeRecycler(kubeClient client.Interface, syncPeriod time.Du
|
|||||||
pv, ok := obj.(*api.PersistentVolume)
|
pv, ok := obj.(*api.PersistentVolume)
|
||||||
if !ok {
|
if !ok {
|
||||||
glog.Errorf("Error casting object to PersistentVolume: %v", obj)
|
glog.Errorf("Error casting object to PersistentVolume: %v", obj)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
recycler.reclaimVolume(pv)
|
recycler.reclaimVolume(pv)
|
||||||
},
|
},
|
||||||
@ -84,6 +85,7 @@ func NewPersistentVolumeRecycler(kubeClient client.Interface, syncPeriod time.Du
|
|||||||
pv, ok := newObj.(*api.PersistentVolume)
|
pv, ok := newObj.(*api.PersistentVolume)
|
||||||
if !ok {
|
if !ok {
|
||||||
glog.Errorf("Error casting object to PersistentVolume: %v", newObj)
|
glog.Errorf("Error casting object to PersistentVolume: %v", newObj)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
recycler.reclaimVolume(pv)
|
recycler.reclaimVolume(pv)
|
||||||
},
|
},
|
||||||
|
Loading…
Reference in New Issue
Block a user