use get parameter for k8s resource watch url

This commit is contained in:
Murat Kabilov
2017-07-17 17:07:16 +02:00
parent 4d936fc3a1
commit 3165106317
+2 -1
View File
@@ -90,8 +90,9 @@ func (c *Controller) clusterListFunc(options meta_v1.ListOptions) (runtime.Objec
}
func (c *Controller) clusterWatchFunc(options meta_v1.ListOptions) (watch.Interface, error) {
options.Watch = true
req := c.RestClient.Get().
RequestURI(fmt.Sprintf(constants.WatchClustersURITemplate, c.opConfig.Namespace)).
RequestURI(fmt.Sprintf(constants.ListClustersURITemplate, c.opConfig.Namespace)).
VersionedParams(&options, scheme.ParameterCodec).
FieldsSelectorParam(fields.Everything())
return req.Watch()