From 4d936fc3a194e485ae592bdcc20710d4dd04f9fd Mon Sep 17 00:00:00 2001 From: Murat Kabilov Date: Mon, 17 Jul 2017 15:21:06 +0200 Subject: [PATCH] use proper ParameterCodec --- pkg/controller/postgresql.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/controller/postgresql.go b/pkg/controller/postgresql.go index a9ceba3c2..f5cd8e6f0 100644 --- a/pkg/controller/postgresql.go +++ b/pkg/controller/postgresql.go @@ -12,7 +12,7 @@ import ( "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/watch" - "k8s.io/client-go/pkg/api" + "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/tools/cache" "github.com/zalando-incubator/postgres-operator/pkg/cluster" @@ -39,7 +39,7 @@ func (c *Controller) clusterListFunc(options meta_v1.ListOptions) (runtime.Objec req := c.RestClient.Get(). RequestURI(fmt.Sprintf(constants.ListClustersURITemplate, c.opConfig.Namespace)). - VersionedParams(&options, api.ParameterCodec). + VersionedParams(&options, scheme.ParameterCodec). FieldsSelectorParam(fields.Everything()) object, err := req.Do().Get() @@ -92,7 +92,7 @@ func (c *Controller) clusterListFunc(options meta_v1.ListOptions) (runtime.Objec func (c *Controller) clusterWatchFunc(options meta_v1.ListOptions) (watch.Interface, error) { req := c.RestClient.Get(). RequestURI(fmt.Sprintf(constants.WatchClustersURITemplate, c.opConfig.Namespace)). - VersionedParams(&options, api.ParameterCodec). + VersionedParams(&options, scheme.ParameterCodec). FieldsSelectorParam(fields.Everything()) return req.Watch() }