Adjustments required for kubernetes group update

Author: tjmoore4

internal/controller/runtime/client.go

@@ -7,6 +7,7 @@ package runtime
 import (
 	"context"
 
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/client-go/rest"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
@@ -32,6 +33,7 @@ type (
 	ClientPatch     func(context.Context, client.Object, client.Patch, ...client.PatchOption) error
 	ClientDeleteAll func(context.Context, client.Object, ...client.DeleteAllOfOption) error
 	ClientUpdate    func(context.Context, client.Object, ...client.UpdateOption) error
+	ClientApply     func(context.Context, runtime.ApplyConfiguration, ...client.ApplyOption) error
 )
 
 // ClientWriter implements [client.Writer] by composing assignable functions.
@@ -41,6 +43,7 @@ type ClientWriter struct {
 	ClientDeleteAll
 	ClientPatch
 	ClientUpdate
+	ClientApply
 }
 
 var _ client.Writer = ClientWriter{}
@@ -76,6 +79,10 @@ func (fn ClientUpdate) Update(ctx context.Context, obj client.Object, opts ...cl
 	return fn(ctx, obj, opts...)
 }
 
+func (fn ClientApply) Apply(ctx context.Context, obj runtime.ApplyConfiguration, opts ...client.ApplyOption) error {
+	return fn(ctx, obj, opts...)
+}
+
 // WarningHandler implements [rest.WarningHandler] and [rest.WarningHandlerWithContext] as a single function.
 type WarningHandler func(ctx context.Context, code int, agent string, text string)
 

internal/controller/runtime/pod_client.go

@@ -30,7 +30,7 @@ func newPodClient(config *rest.Config) (rest.Interface, error) {
 	if err != nil {
 		return nil, err
 	}
-	return apiutil.RESTClientForGVK(gvk, false, config, codecs, httpClient)
+	return apiutil.RESTClientForGVK(gvk, false, false, config, codecs, httpClient)
 }
 
 // +kubebuilder:rbac:groups="",resources="pods/exec",verbs={create}