parent
2bf9acd95e
commit
b4ea68b88a
1 changed files with 1 additions and 1 deletions
|
@ -248,7 +248,7 @@ func (c *clientImpl) watch(url string, labelSelector string, stopCh <-chan bool)
|
||||||
return watchCh, errCh, fmt.Errorf("failed to decode version %v", err)
|
return watchCh, errCh, fmt.Errorf("failed to decode version %v", err)
|
||||||
}
|
}
|
||||||
resourceVersion := generic.ResourceVersion
|
resourceVersion := generic.ResourceVersion
|
||||||
queryParams := map[string]string{"watch": "", "resourceVersion": resourceVersion}
|
queryParams := map[string]string{"watch": "true", "resourceVersion": resourceVersion}
|
||||||
queryData, err := makeQueryString(queryParams, labelSelector)
|
queryData, err := makeQueryString(queryParams, labelSelector)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return watchCh, errCh, fmt.Errorf("Unable to construct query args")
|
return watchCh, errCh, fmt.Errorf("Unable to construct query args")
|
||||||
|
|
Loading…
Add table
Reference in a new issue