Resolve context argument missing

go.mod

@@ -3,16 +3,10 @@ module github.com/IBM/multi-cluster-app-dispatcher
 go 1.16
 
 require (
-github.com/emicklei/go-restful v2.9.5+incompatible
-github.com/emicklei/go-restful-swagger12 v0.0.0-20201014110547-68ccff494617
-github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b
 github.com/googleapis/gnostic v0.4.1 // indirect
-github.com/spf13/pflag v1.0.5
-k8s.io/api v0.21.0
-k8s.io/apiextensions-apiserver v0.21.0
-k8s.io/apimachinery v0.21.0
-k8s.io/apiserver v0.21.0
-k8s.io/client-go v0.21.0
-k8s.io/gengo v0.0.0-20201214224949-b6c5ce23f027
-k8s.io/metrics v0.19.0
+github.com/spf13/pflag v1.0.5 // indirect
+k8s.io/api v0.19.0 // indirect
+k8s.io/apimachinery v0.19.0 // indirect
+k8s.io/client-go v0.19.0 // indirect
+k8s.io/metrics v0.19.0 // indirect
 )

pkg/client/clientset/controller-versioned/clients/appwrapper.go

@@ -17,6 +17,7 @@ limitations under the License.
 package clients
 
 import (
+"context"
 "fmt"
 "reflect"
 "time"
@@ -48,15 +49,15 @@ func CreateAppWrapperKind(clientset apiextensionsclient.Interface) (*apiextensio
 },
 },
 }
-_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(crd)
+_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(context.Background(), crd, nil)
 
 if err != nil {
 return nil, err
 }
 
 // wait for CRD being established
 err = wait.Poll(500*time.Millisecond, 60*time.Second, func() (bool, error) {
-crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(appWrapperKindName, metav1.GetOptions{})
+crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(context.Background(), appWrapperKindName, metav1.GetOptions{})
 if err != nil {
 return false, err
 }
@@ -75,7 +76,7 @@ func CreateAppWrapperKind(clientset apiextensionsclient.Interface) (*apiextensio
 return false, err
 })
 if err != nil {
-deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(appWrapperKindName, nil)
+deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(context.Background(), appWrapperKindName, nil)
 if deleteErr != nil {
 return nil, errors.NewAggregate([]error{err, deleteErr})
 }

pkg/client/clientset/controller-versioned/clients/queuejob.go

@@ -17,6 +17,7 @@ limitations under the License.
 package clients
 
 import (
+"context"
 "fmt"
 "reflect"
 "time"
@@ -48,15 +49,15 @@ func CreateQueueJobKind(clientset apiextensionsclient.Interface) (*apiextensions
 },
 },
 }
-_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(crd)
+_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(context.Background(), crd)
 
 if err != nil {
 return nil, err
 }
 
 // wait for CRD being established
 err = wait.Poll(500*time.Millisecond, 60*time.Second, func() (bool, error) {
-crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(queueJobKindName, metav1.GetOptions{})
+crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(context.Background(), queueJobKindName, metav1.GetOptions{})
 if err != nil {
 return false, err
 }
@@ -75,7 +76,7 @@ func CreateQueueJobKind(clientset apiextensionsclient.Interface) (*apiextensions
 return false, err
 })
 if err != nil {
-deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(queueJobKindName, nil)
+deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(context.Background(), queueJobKindName, nil)
 if deleteErr != nil {
 return nil, errors.NewAggregate([]error{err, deleteErr})
 }

pkg/client/clientset/controller-versioned/clients/schedulingspec.go

@@ -17,6 +17,7 @@ limitations under the License.
 package clients
 
 import (
+"context"
 "fmt"
 "reflect"
 "time"
@@ -48,16 +49,15 @@ func CreateSchedulingSpecKind(clientset apiextensionsclient.Interface) (*apiexte
 },
 },
 }
-_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(crd)
+_, err := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Create(context.Background(), crd)
 
 if err != nil {
 return nil, err
 }
 
 // wait for CRD being established
 err = wait.Poll(500*time.Millisecond, 60*time.Second, func() (bool, error) {
-crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(
-schedulingSpecKindName, metav1.GetOptions{})
+crd, err = clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Get(context.Background(), schedulingSpecKindName, metav1.GetOptions{})
 if err != nil {
 return false, err
 }
@@ -76,8 +76,7 @@ func CreateSchedulingSpecKind(clientset apiextensionsclient.Interface) (*apiexte
 return false, err
 })
 if err != nil {
-deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(
-schedulingSpecKindName, nil)
+deleteErr := clientset.ApiextensionsV1beta1().CustomResourceDefinitions().Delete(context.Background(), schedulingSpecKindName, nil)
 if deleteErr != nil {
 return nil, errors.NewAggregate([]error{err, deleteErr})
 }

pkg/client/clientset/controller-versioned/typed/v1/appwrapper.go

@@ -17,6 +17,8 @@ limitations under the License.
 package v1
 
 import (
+"context"
+
 v1 "github.com/IBM/multi-cluster-app-dispatcher/pkg/apis/controller/v1alpha1"
 "github.com/IBM/multi-cluster-app-dispatcher/pkg/client/clientset/controller-versioned/scheme"
 
@@ -58,7 +60,7 @@ func (c *appwrappers) Create(appwrapper *v1.AppWrapper) (result *v1.AppWrapper,
 Namespace(c.ns).
 Resource(v1.AppWrapperPlural).
 Body(appwrapper).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -71,7 +73,7 @@ func (c *appwrappers) Update(appwrapper *v1.AppWrapper) (result *v1.AppWrapper,
 Resource(v1.AppWrapperPlural).
 Name(appwrapper.Name).
 Body(appwrapper).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -87,7 +89,7 @@ func (c *appwrappers) UpdateStatus(appwrapper *v1.AppWrapper) (result *v1.AppWra
 Name(appwrapper.Name).
 SubResource("status").
 Body(appwrapper).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -99,7 +101,7 @@ func (c *appwrappers) Delete(name string, options *meta_v1.DeleteOptions) error
 Resource(v1.AppWrapperPlural).
 Name(name).
 Body(options).
-Do().
+Do(context.Background()).
 Error()
 }
 
@@ -111,7 +113,7 @@ func (c *appwrappers) Get(name string, options meta_v1.GetOptions) (result *v1.A
 Resource(v1.AppWrapperPlural).
 Name(name).
 VersionedParams(&options, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -123,7 +125,7 @@ func (c *appwrappers) List(opts meta_v1.ListOptions) (result *v1.AppWrapperList,
 Namespace(c.ns).
 Resource(v1.AppWrapperPlural).
 VersionedParams(&opts, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }

pkg/client/clientset/controller-versioned/typed/v1/client.go

@@ -85,7 +85,7 @@ func setConfigDefaults(config *rest.Config) error {
 config.GroupVersion = &v1.SchemeGroupVersion
 config.APIPath = "/apis"
 config.ContentType = runtime.ContentTypeJSON
-config.NegotiatedSerializer = serializer.DirectCodecFactory{CodecFactory: serializer.NewCodecFactory(scheme)}
+config.NegotiatedSerializer = serializer.WithoutConversionCodecFactory{CodecFactory: serializer.NewCodecFactory(scheme)} // serializer.DirectCodecFactory{CodecFactory: serializer.NewCodecFactory(scheme)}
 
 return nil
 }

pkg/client/clientset/controller-versioned/typed/v1/queuejob.go

@@ -17,6 +17,8 @@ limitations under the License.
 package v1
 
 import (
+"context"
+
 v1 "github.com/IBM/multi-cluster-app-dispatcher/pkg/apis/controller/v1alpha1"
 "github.com/IBM/multi-cluster-app-dispatcher/pkg/client/clientset/controller-versioned/scheme"
 
@@ -58,7 +60,7 @@ func (c *queuejobs) Create(queuejob *v1.QueueJob) (result *v1.QueueJob, err erro
 Namespace(c.ns).
 Resource(v1.QueueJobPlural).
 Body(queuejob).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -71,7 +73,7 @@ func (c *queuejobs) Update(queuejob *v1.QueueJob) (result *v1.QueueJob, err erro
 Resource(v1.QueueJobPlural).
 Name(queuejob.Name).
 Body(queuejob).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -87,7 +89,7 @@ func (c *queuejobs) UpdateStatus(queuejob *v1.QueueJob) (result *v1.QueueJob, er
 Name(queuejob.Name).
 SubResource("status").
 Body(queuejob).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -99,7 +101,7 @@ func (c *queuejobs) Delete(name string, options *meta_v1.DeleteOptions) error {
 Resource(v1.QueueJobPlural).
 Name(name).
 Body(options).
-Do().
+Do(context.Background()).
 Error()
 }
 
@@ -111,7 +113,7 @@ func (c *queuejobs) Get(name string, options meta_v1.GetOptions) (result *v1.Que
 Resource(v1.QueueJobPlural).
 Name(name).
 VersionedParams(&options, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -123,7 +125,7 @@ func (c *queuejobs) List(opts meta_v1.ListOptions) (result *v1.QueueJobList, err
 Namespace(c.ns).
 Resource(v1.QueueJobPlural).
 VersionedParams(&opts, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }

pkg/client/clientset/controller-versioned/typed/v1/schedulingspec.go

@@ -17,6 +17,8 @@ limitations under the License.
 package v1
 
 import (
+"context"
+
 v1 "github.com/IBM/multi-cluster-app-dispatcher/pkg/apis/controller/v1alpha1"
 "github.com/IBM/multi-cluster-app-dispatcher/pkg/client/clientset/controller-versioned/scheme"
 
@@ -58,7 +60,7 @@ func (c *schedulingSpecs) Create(queue *v1.SchedulingSpec) (result *v1.Schedulin
 Namespace(c.ns).
 Resource(v1.SchedulingSpecPlural).
 Body(queue).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -71,7 +73,7 @@ func (c *schedulingSpecs) Update(queue *v1.SchedulingSpec) (result *v1.Schedulin
 Resource(v1.SchedulingSpecPlural).
 Name(queue.Name).
 Body(queue).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -87,7 +89,7 @@ func (c *schedulingSpecs) UpdateStatus(queue *v1.SchedulingSpec) (result *v1.Sch
 Name(queue.Name).
 SubResource("status").
 Body(queue).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -99,7 +101,7 @@ func (c *schedulingSpecs) Delete(name string, options *meta_v1.DeleteOptions) er
 Resource(v1.SchedulingSpecPlural).
 Name(name).
 Body(options).
-Do().
+Do(context.Background()).
 Error()
 }
 
@@ -111,7 +113,7 @@ func (c *schedulingSpecs) Get(name string, options meta_v1.GetOptions) (result *
 Resource(v1.SchedulingSpecPlural).
 Name(name).
 VersionedParams(&options, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }
@@ -123,7 +125,7 @@ func (c *schedulingSpecs) List(opts meta_v1.ListOptions) (result *v1.SchedulingS
 Namespace(c.ns).
 Resource(v1.SchedulingSpecPlural).
 VersionedParams(&opts, scheme.ParameterCodec).
-Do().
+Do(context.Background()).
 Into(result)
 return
 }

pkg/controller/metrics/dynamicmapper/fake_discovery.go

@@ -20,7 +20,7 @@ import (
 "fmt"
 
 swagger "github.com/emicklei/go-restful-swagger12"
-openapi_v2 "github.com/googleapis/gnostic/openapiv2" // Nhan edited
+openapi_v2 "github.com/googleapis/gnostic/openapiv2" // fix case sensitive
 v1 "k8s.io/api/core/v1"
 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 "k8s.io/apimachinery/pkg/runtime/schema"

pkg/controller/metrics/provider/helpers/helpers.go

@@ -17,6 +17,7 @@ limitations under the License.
 package helpers
 
 import (
+"context"
 "fmt"
 
 apimeta "k8s.io/apimachinery/pkg/api/meta"
@@ -83,7 +84,7 @@ func ListObjectNames(mapper apimeta.RESTMapper, client dynamic.Interface, namesp
 resClient = client.Resource(res)
 }
 
-matchingObjectsRaw, err := resClient.List(metav1.ListOptions{LabelSelector: selector.String()})
+matchingObjectsRaw, err := resClient.List(context.Background(), metav1.ListOptions{LabelSelector: selector.String()})
 if err != nil {
 return nil, err
 }