[tests] Make compatible with Kubernetes v1.20.1

Author: Christian Weichel

test/pkg/integration/apis.go

@@ -144,7 +144,7 @@ func (c *ComponentAPI) GitpodServer(opts ...GitpodServerOpt) (res gitpod.APIInte
 			c.serverStatus.Token[options.User] = tkn
 		}
 
-		pods, err := c.t.clientset.CoreV1().Pods(c.t.namespace).List(metav1.ListOptions{
+		pods, err := c.t.clientset.CoreV1().Pods(c.t.namespace).List(context.Background(), metav1.ListOptions{
 			LabelSelector: "component=server",
 		})
 		if err != nil {
@@ -315,12 +315,12 @@ func (c *ComponentAPI) DB() *sql.DB {
 	}()
 
 	if c.dbStatus.Port == 0 {
-		svc, err := c.t.clientset.CoreV1().Services(c.t.namespace).Get("db", metav1.GetOptions{})
+		svc, err := c.t.clientset.CoreV1().Services(c.t.namespace).Get(context.Background(), "db", metav1.GetOptions{})
 		if err != nil {
 			rerr = err
 			return nil
 		}
-		pods, err := c.t.clientset.CoreV1().Pods(c.t.namespace).List(metav1.ListOptions{
+		pods, err := c.t.clientset.CoreV1().Pods(c.t.namespace).List(context.Background(), metav1.ListOptions{
 			LabelSelector: labels.SelectorFromSet(svc.Spec.Selector).String(),
 		})
 		if err != nil {
@@ -375,7 +375,7 @@ func (c *ComponentAPI) DB() *sql.DB {
 		c.dbStatus.Port = localPort
 	}
 	if c.dbStatus.Password == "" {
-		sct, err := c.t.clientset.CoreV1().Secrets(c.t.namespace).Get("db-password", metav1.GetOptions{})
+		sct, err := c.t.clientset.CoreV1().Secrets(c.t.namespace).Get(context.Background(), "db-password", metav1.GetOptions{})
 		if err != nil {
 			rerr = err
 			return nil

test/pkg/integration/integration.go

@@ -478,7 +478,7 @@ func (t *Test) selectPod(component ComponentType, options selectPodOptions) (pod
 	}
 	if component == ComponentWorkspaceDaemon && options.InstanceID != "" {
 		var pods *corev1.PodList
-		pods, err = t.clientset.CoreV1().Pods(t.namespace).List(metav1.ListOptions{
+		pods, err = t.clientset.CoreV1().Pods(t.namespace).List(context.Background(), metav1.ListOptions{
 			LabelSelector: "component=workspace,workspaceID=" + options.InstanceID,
 		})
 		if err != nil {
@@ -492,7 +492,7 @@ func (t *Test) selectPod(component ComponentType, options selectPodOptions) (pod
 		listOptions.FieldSelector = "spec.nodeName=" + pods.Items[0].Spec.NodeName
 	}
 
-	pods, err := t.clientset.CoreV1().Pods(t.namespace).List(listOptions)
+	pods, err := t.clientset.CoreV1().Pods(t.namespace).List(context.Background(), listOptions)
 	if err != nil {
 		err = xerrors.Errorf("cannot list pods: %w", err)
 		return

test/pkg/integration/workspace.go

@@ -132,7 +132,7 @@ func LaunchWorkspaceDirectly(it *Test, opts ...LaunchWorkspaceDirectlyOpt) (res
 
 	ideImage := options.IdeImage
 	if ideImage == "" {
-		pods, err := it.clientset.CoreV1().Pods(it.namespace).List(metav1.ListOptions{
+		pods, err := it.clientset.CoreV1().Pods(it.namespace).List(context.Background(), metav1.ListOptions{
 			LabelSelector: "component=server",
 		})
 		if err != nil {