Use k8s 1.29 client libs

Signed-off-by: Tamal Saha <tamal@appscode.com>

Author: tamalsaha

.github/workflows/ci.yml

@@ -16,12 +16,12 @@ concurrency:
 jobs:
   build:
     name: Build
-    runs-on: ubuntu-20.04
+    runs-on: ubuntu-22.04
     steps:
-      - name: Set up Go 1.20
+      - name: Set up Go 1.21
         uses: actions/setup-go@v1
         with:
-          go-version: '1.20'
+          go-version: '1.21'
         id: go
 
       - uses: actions/checkout@v1

.github/workflows/release-tracker.yml

@@ -11,7 +11,7 @@ concurrency:
 
 jobs:
   build:
-    runs-on: ubuntu-20.04
+    runs-on: ubuntu-22.04
 
     steps:
       - uses: actions/checkout@v1

.github/workflows/release.yml

@@ -13,7 +13,7 @@ concurrency:
 jobs:
   build:
     name: Build
-    runs-on: ubuntu-20.04
+    runs-on: ubuntu-22.04
     steps:
       - uses: actions/checkout@v1
 

cmd/demo-client/main.go

@@ -28,6 +28,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
+	"k8s.io/client-go/rest"
 	"k8s.io/klog/v2/klogr"
 	clustermeta "kmodules.xyz/client-go/cluster"
 	ctrl "sigs.k8s.io/controller-runtime"
@@ -52,15 +53,19 @@ func main() {
 	// 		panic(err)
 	// 	}
 
-	mapper, err := apiutil.NewDynamicRESTMapper(config)
+	hc, err := rest.HTTPClientFor(config)
+	if err != nil {
+		panic(err)
+	}
+	mapper, err := apiutil.NewDynamicRESTMapper(config, hc)
 	if err != nil {
 		panic(err)
 	}
 
 	c, err := client.New(config, client.Options{
 		Scheme: clientgoscheme.Scheme,
 		Mapper: mapper,
-		Opts: client.WarningHandlerOptions{
+		WarningHandler: client.WarningHandlerOptions{
 			SuppressWarnings:   false,
 			AllowDuplicateLogs: false,
 		},

cmd/demo-server/main.go

@@ -32,6 +32,7 @@ import (
 	"go.wandrs.dev/inject"
 	"gomodules.xyz/blobfs"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
+	"k8s.io/client-go/rest"
 	"k8s.io/klog/v2/klogr"
 	clustermeta "kmodules.xyz/client-go/cluster"
 	"kubepack.dev/lib-helm/pkg/repo"
@@ -105,15 +106,19 @@ func getNatsClient() (*nats.Conn, error) {
 	// 		panic(err)
 	// 	}
 
-	mapper, err := apiutil.NewDynamicRESTMapper(config)
+	hc, err := rest.HTTPClientFor(config)
+	if err != nil {
+		return nil, err
+	}
+	mapper, err := apiutil.NewDynamicRESTMapper(config, hc)
 	if err != nil {
 		return nil, err
 	}
 
 	c, err := client.New(config, client.Options{
 		Scheme: clientgoscheme.Scheme,
 		Mapper: mapper,
-		Opts: client.WarningHandlerOptions{
+		WarningHandler: client.WarningHandlerOptions{
 			SuppressWarnings:   false,
 			AllowDuplicateLogs: false,
 		},

cmd/proxy-server/main.go

@@ -39,6 +39,7 @@ import (
 	"k8s.io/apimachinery/pkg/api/errors"
 	utilnet "k8s.io/apimachinery/pkg/util/net"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
+	"k8s.io/client-go/rest"
 	"k8s.io/klog/v2/klogr"
 	clustermeta "kmodules.xyz/client-go/cluster"
 	ctrl "sigs.k8s.io/controller-runtime"
@@ -136,15 +137,19 @@ func getNatsClient() (*nats.Conn, error) {
 	// 		panic(err)
 	// 	}
 
-	mapper, err := apiutil.NewDynamicRESTMapper(config)
+	hc, err := rest.HTTPClientFor(config)
+	if err != nil {
+		return nil, err
+	}
+	mapper, err := apiutil.NewDynamicRESTMapper(config, hc)
 	if err != nil {
 		return nil, err
 	}
 
 	c, err := client.New(config, client.Options{
 		Scheme: clientgoscheme.Scheme,
 		Mapper: mapper,
-		Opts: client.WarningHandlerOptions{
+		WarningHandler: client.WarningHandlerOptions{
 			SuppressWarnings:   false,
 			AllowDuplicateLogs: false,
 		},