github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-09-17 15:47:48 +00:00
Code Issues Projects Releases Wiki Activity

Handle unstructured status in RetryWatcher

Browse Source 
Kubernetes-commit: 8302b5b262c506ff7d363338f980ce204d574354
This commit is contained in:
Tomas Nozicka
2019-03-08 09:34:56 +01:00
committed by Kubernetes Publisher
parent dfef1155b5
commit 54b354c5dc
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tools/watch/retrywatcher.go
View File

@@ -184,13 +184,17 @@ func (rw *RetryWatcher) doReceive() (bool, time.Duration) {
continue
case watch.Error:
status, ok := event.Object.(*metav1.Status)
// This round trip allows us to handle unstructured status
errObject := apierrors.FromObject(event.Object)
statusErr, ok := errObject.(*apierrors.StatusError)
if !ok {
klog.Error(spew.Sprintf("Received an error which is not *metav1.Status but %#+v", event.Object))
// Retry unknown errors
return false, 0
}
status := statusErr.ErrStatus
statusDelay := time.Duration(0)
if status.Details != nil {
statusDelay = time.Duration(status.Details.RetryAfterSeconds) * time.Second