dev: separate kube context

sunsingerus · sunsingerus · commit b7f36f0f1bd7 · 2025-07-10T12:48:21.000+03:00
diff --git a/pkg/controller/chi/kube/config-map.go b/pkg/controller/chi/kube/config-map.go
@@ -39,18 +39,22 @@ func NewConfigMap(kubeClient kube.Interface) *ConfigMap {
 }
 
 func (c *ConfigMap) Create(ctx context.Context, cm *core.ConfigMap) (*core.ConfigMap, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().ConfigMaps(cm.Namespace).Create(ctx, cm, controller.NewCreateOptions())
 }
 
 func (c *ConfigMap) Get(ctx context.Context, namespace, name string) (*core.ConfigMap, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().ConfigMaps(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *ConfigMap) Update(ctx context.Context, cm *core.ConfigMap) (*core.ConfigMap, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().ConfigMaps(cm.Namespace).Update(ctx, cm, controller.NewUpdateOptions())
 }
 
 func (c *ConfigMap) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	c.kubeClient.CoreV1().ConfigMaps(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 	return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).
 		WithOptions(poller.NewOptions().FromConfig(chop.Config())).
@@ -63,6 +67,7 @@ func (c *ConfigMap) Delete(ctx context.Context, namespace, name string) error {
 }
 
 func (c *ConfigMap) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.ConfigMap, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.CoreV1().ConfigMaps(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err
diff --git a/pkg/controller/chi/kube/context.go b/pkg/controller/chi/kube/context.go
@@ -0,0 +1,21 @@
+// Copyright 2019 Altinity Ltd and/or its affiliates. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package kube
+
+import "context"
+
+func k8sCtx(ctx context.Context) context.Context {
+	return context.Background()
+}
diff --git a/pkg/controller/chi/kube/cr.go b/pkg/controller/chi/kube/cr.go
@@ -52,6 +52,8 @@ func NewCR(chopClient chopClientSet.Interface, kubeClient kube.Interface) *CR {
 }
 
 func (c *CR) Get(ctx context.Context, namespace, name string) (api.ICustomResource, error) {
+	ctx = k8sCtx(ctx)
+
 	chi, err := c.getCR(ctx, namespace, name)
 	if err != nil {
 		return nil, err
@@ -65,10 +67,12 @@ func (c *CR) Get(ctx context.Context, namespace, name string) (api.ICustomResour
 }
 
 func (c *CR) getCR(ctx context.Context, namespace, name string) (*api.ClickHouseInstallation, error) {
+	ctx = k8sCtx(ctx)
 	return c.chopClient.ClickhouseV1().ClickHouseInstallations(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *CR) getCM(ctx context.Context, chi api.ICustomResource) (*core.ConfigMap, error) {
+	ctx = k8sCtx(ctx)
 	return NewConfigMap(c.kubeClient).Get(ctx, c.buildCMNamespace(chi), c.buildCMName(chi))
 }
 
@@ -99,7 +103,7 @@ func (c *CR) buildCR(chi *api.ClickHouseInstallation, cm *core.ConfigMap) *api.C
 // StatusUpdate updates CR object's Status
 func (c *CR) StatusUpdate(ctx context.Context, cr api.ICustomResource, opts commonTypes.UpdateStatusOptions) error {
 	if util.IsContextDone(ctx) {
-		log.V(2).Info("task is done")
+		log.V(1).Info("Reconcile is aborted. cr: %s ", cr.GetName())
 		return nil
 	}
 
@@ -130,7 +134,7 @@ func (c *CR) statusUpdateRetry(ctx context.Context, cr api.ICustomResource, opts
 // statusUpdateProcess updates CR object's Status
 func (c *CR) statusUpdateProcess(ctx context.Context, icr api.ICustomResource, opts commonTypes.UpdateStatusOptions) error {
 	if util.IsContextDone(ctx) {
-		log.V(2).Info("task is done")
+		log.V(1).Info("Reconcile is aborted. cr: %s ", icr.GetName())
 		return nil
 	}
 
diff --git a/pkg/controller/chi/kube/deployment.go b/pkg/controller/chi/kube/deployment.go
@@ -32,9 +32,11 @@ func NewDeployment(kubeClient kube.Interface) *Deployment {
 }
 
 func (c *Deployment) Get(namespace, name string) (*apps.Deployment, error) {
-	return c.kubeClient.AppsV1().Deployments(namespace).Get(controller.NewContext(), name, controller.NewGetOptions())
+	ctx := k8sCtx(controller.NewContext())
+	return c.kubeClient.AppsV1().Deployments(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *Deployment) Update(deployment *apps.Deployment) (*apps.Deployment, error) {
-	return c.kubeClient.AppsV1().Deployments(deployment.Namespace).Update(controller.NewContext(), deployment, controller.NewUpdateOptions())
+	ctx := k8sCtx(controller.NewContext())
+	return c.kubeClient.AppsV1().Deployments(deployment.Namespace).Update(ctx, deployment, controller.NewUpdateOptions())
 }
diff --git a/pkg/controller/chi/kube/event.go b/pkg/controller/chi/kube/event.go
@@ -34,5 +34,6 @@ func NewEvent(kubeClient kube.Interface) *Event {
 }
 
 func (c *Event) Create(ctx context.Context, event *core.Event) (*core.Event, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Events(event.Namespace).Create(ctx, event, controller.NewCreateOptions())
 }
diff --git a/pkg/controller/chi/kube/pdb.go b/pkg/controller/chi/kube/pdb.go
@@ -39,18 +39,22 @@ func NewPDB(kubeClient kube.Interface) *PDB {
 }
 
 func (c *PDB) Create(ctx context.Context, pdb *policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.PolicyV1().PodDisruptionBudgets(pdb.Namespace).Create(ctx, pdb, controller.NewCreateOptions())
 }
 
 func (c *PDB) Get(ctx context.Context, namespace, name string) (*policy.PodDisruptionBudget, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *PDB) Update(ctx context.Context, pdb *policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.PolicyV1().PodDisruptionBudgets(pdb.Namespace).Update(ctx, pdb, controller.NewUpdateOptions())
 }
 
 func (c *PDB) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 	return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).
 		WithOptions(poller.NewOptions().FromConfig(chop.Config())).
@@ -63,6 +67,7 @@ func (c *PDB) Delete(ctx context.Context, namespace, name string) error {
 }
 
 func (c *PDB) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]policy.PodDisruptionBudget, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err
diff --git a/pkg/controller/chi/kube/pod.go b/pkg/controller/chi/kube/pod.go
@@ -65,7 +65,8 @@ func (c *Pod) Get(params ...any) (*core.Pod, error) {
 	default:
 		panic(any("incorrect number or params"))
 	}
-	return c.kubeClient.CoreV1().Pods(namespace).Get(controller.NewContext(), name, controller.NewGetOptions())
+	ctx := k8sCtx(controller.NewContext())
+	return c.kubeClient.CoreV1().Pods(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *Pod) GetRestartCounters(params ...any) (map[string]int, error) {
@@ -93,6 +94,7 @@ func (c *Pod) GetAll(obj any) []*core.Pod {
 }
 
 func (c *Pod) Update(ctx context.Context, pod *core.Pod) (*core.Pod, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Pods(pod.GetNamespace()).Update(ctx, pod, controller.NewUpdateOptions())
 }
 
@@ -118,5 +120,6 @@ func (c *Pod) getPod(host *api.Host) (pods []*core.Pod) {
 }
 
 func (c *Pod) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Pods(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 }
diff --git a/pkg/controller/chi/kube/pvc.go b/pkg/controller/chi/kube/pvc.go
@@ -38,22 +38,27 @@ func NewPVC(kubeClient kube.Interface) *PVC {
 }
 
 func (c *PVC) Create(ctx context.Context, pvc *core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace).Create(ctx, pvc, controller.NewCreateOptions())
 }
 
 func (c *PVC) Get(ctx context.Context, namespace, name string) (*core.PersistentVolumeClaim, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *PVC) Update(ctx context.Context, pvc *core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace).Update(ctx, pvc, controller.NewUpdateOptions())
 }
 
 func (c *PVC) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 }
 
 func (c *PVC) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.PersistentVolumeClaim, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err
@@ -65,6 +70,7 @@ func (c *PVC) List(ctx context.Context, namespace string, opts meta.ListOptions)
 }
 
 func (c *PVC) ListForHost(ctx context.Context, host *api.Host) (*core.PersistentVolumeClaimList, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.
 		CoreV1().
 		PersistentVolumeClaims(host.Runtime.Address.Namespace).
diff --git a/pkg/controller/chi/kube/replicaset.go b/pkg/controller/chi/kube/replicaset.go
@@ -34,9 +34,11 @@ func NewReplicaSet(kubeClient kube.Interface) *ReplicaSet {
 }
 
 func (c *ReplicaSet) Get(ctx context.Context, namespace, name string) (*apps.ReplicaSet, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.AppsV1().ReplicaSets(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *ReplicaSet) Update(ctx context.Context, replicaSet *apps.ReplicaSet) (*apps.ReplicaSet, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.AppsV1().ReplicaSets(replicaSet.Namespace).Update(ctx, replicaSet, controller.NewUpdateOptions())
 }
diff --git a/pkg/controller/chi/kube/secret.go b/pkg/controller/chi/kube/secret.go
@@ -64,18 +64,22 @@ func (c *Secret) Get(ctx context.Context, params ...any) (*core.Secret, error) {
 			namespace = typedObj.Runtime.Address.Namespace
 		}
 	}
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Secrets(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *Secret) Create(ctx context.Context, svc *core.Secret) (*core.Secret, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Secrets(svc.Namespace).Create(ctx, svc, controller.NewCreateOptions())
 }
 
 func (c *Secret) Update(ctx context.Context, svc *core.Secret) (*core.Secret, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Secrets(svc.Namespace).Update(ctx, svc, controller.NewUpdateOptions())
 }
 
 func (c *Secret) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	c.kubeClient.CoreV1().Secrets(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 	return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).
 		WithOptions(poller.NewOptions().FromConfig(chop.Config())).
@@ -89,6 +93,7 @@ func (c *Secret) Delete(ctx context.Context, namespace, name string) error {
 }
 
 func (c *Secret) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.Secret, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.CoreV1().Secrets(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err
diff --git a/pkg/controller/chi/kube/service.go b/pkg/controller/chi/kube/service.go
@@ -64,18 +64,22 @@ func (c *Service) Get(ctx context.Context, params ...any) (*core.Service, error)
 			namespace = typedObj.Runtime.Address.Namespace
 		}
 	}
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Services(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *Service) Create(ctx context.Context, svc *core.Service) (*core.Service, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Services(svc.Namespace).Create(ctx, svc, controller.NewCreateOptions())
 }
 
 func (c *Service) Update(ctx context.Context, svc *core.Service) (*core.Service, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.CoreV1().Services(svc.Namespace).Update(ctx, svc, controller.NewUpdateOptions())
 }
 
 func (c *Service) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	c.kubeClient.CoreV1().Services(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 	return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).
 		WithOptions(poller.NewOptions().FromConfig(chop.Config())).
@@ -88,6 +92,7 @@ func (c *Service) Delete(ctx context.Context, namespace, name string) error {
 }
 
 func (c *Service) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.Service, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.CoreV1().Services(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err
diff --git a/pkg/controller/chi/kube/statesfulset.go b/pkg/controller/chi/kube/statesfulset.go
@@ -69,20 +69,24 @@ func (c *STS) Get(ctx context.Context, params ...any) (*apps.StatefulSet, error)
 	default:
 		panic("unexxpected number of args")
 	}
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.AppsV1().StatefulSets(namespace).Get(ctx, name, controller.NewGetOptions())
 }
 
 func (c *STS) Create(ctx context.Context, statefulSet *apps.StatefulSet) (*apps.StatefulSet, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.AppsV1().StatefulSets(statefulSet.Namespace).Create(ctx, statefulSet, controller.NewCreateOptions())
 }
 
 // Update is an internal function, used in reconcileStatefulSet only
 func (c *STS) Update(ctx context.Context, sts *apps.StatefulSet) (*apps.StatefulSet, error) {
+	ctx = k8sCtx(ctx)
 	return c.kubeClient.AppsV1().StatefulSets(sts.Namespace).Update(ctx, sts, controller.NewUpdateOptions())
 }
 
 // Delete gracefully deletes StatefulSet through zeroing Pod's count
 func (c *STS) Delete(ctx context.Context, namespace, name string) error {
+	ctx = k8sCtx(ctx)
 	c.kubeClient.AppsV1().StatefulSets(namespace).Delete(ctx, name, controller.NewDeleteOptions())
 	return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).
 		WithOptions(poller.NewOptions().FromConfig(chop.Config())).
@@ -95,6 +99,7 @@ func (c *STS) Delete(ctx context.Context, namespace, name string) error {
 }
 
 func (c *STS) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]apps.StatefulSet, error) {
+	ctx = k8sCtx(ctx)
 	list, err := c.kubeClient.AppsV1().StatefulSets(namespace).List(ctx, opts)
 	if err != nil {
 		return nil, err

Original file line number	Diff line number	Diff line change
`@@ -39,18 +39,22 @@ func NewConfigMap(kubeClient kube.Interface) *ConfigMap {`
`39`	`39`	`}`
`40`	`40`
`41`	`41`	`func (c ConfigMap) Create(ctx context.Context, cm core.ConfigMap) (*core.ConfigMap, error) {`
	`42`	`+ ctx = k8sCtx(ctx)`
`42`	`43`	`return c.kubeClient.CoreV1().ConfigMaps(cm.Namespace).Create(ctx, cm, controller.NewCreateOptions())`
`43`	`44`	`}`
`44`	`45`
`45`	`46`	`func (c ConfigMap) Get(ctx context.Context, namespace, name string) (core.ConfigMap, error) {`
	`47`	`+ ctx = k8sCtx(ctx)`
`46`	`48`	`return c.kubeClient.CoreV1().ConfigMaps(namespace).Get(ctx, name, controller.NewGetOptions())`
`47`	`49`	`}`
`48`	`50`
`49`	`51`	`func (c ConfigMap) Update(ctx context.Context, cm core.ConfigMap) (*core.ConfigMap, error) {`
	`52`	`+ ctx = k8sCtx(ctx)`
`50`	`53`	`return c.kubeClient.CoreV1().ConfigMaps(cm.Namespace).Update(ctx, cm, controller.NewUpdateOptions())`
`51`	`54`	`}`
`52`	`55`
`53`	`56`	`func (c *ConfigMap) Delete(ctx context.Context, namespace, name string) error {`
	`57`	`+ ctx = k8sCtx(ctx)`
`54`	`58`	`c.kubeClient.CoreV1().ConfigMaps(namespace).Delete(ctx, name, controller.NewDeleteOptions())`
`55`	`59`	`return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).`
`56`	`60`	`WithOptions(poller.NewOptions().FromConfig(chop.Config())).`
`@@ -63,6 +67,7 @@ func (c *ConfigMap) Delete(ctx context.Context, namespace, name string) error {`
`63`	`67`	`}`
`64`	`68`
`65`	`69`	`func (c *ConfigMap) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.ConfigMap, error) {`
	`70`	`+ ctx = k8sCtx(ctx)`
`66`	`71`	`list, err := c.kubeClient.CoreV1().ConfigMaps(namespace).List(ctx, opts)`
`67`	`72`	`if err != nil {`
`68`	`73`	`return nil, err`
Original file line number	Diff line number	Diff line change
`@@ -52,6 +52,8 @@ func NewCR(chopClient chopClientSet.Interface, kubeClient kube.Interface) *CR {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`func (c *CR) Get(ctx context.Context, namespace, name string) (api.ICustomResource, error) {`
	`55`	`+ ctx = k8sCtx(ctx)`
	`56`	`+`
`55`	`57`	`chi, err := c.getCR(ctx, namespace, name)`
`56`	`58`	`if err != nil {`
`57`	`59`	`return nil, err`
`@@ -65,10 +67,12 @@ func (c *CR) Get(ctx context.Context, namespace, name string) (api.ICustomResour`
`65`	`67`	`}`
`66`	`68`
`67`	`69`	`func (c CR) getCR(ctx context.Context, namespace, name string) (api.ClickHouseInstallation, error) {`
	`70`	`+ ctx = k8sCtx(ctx)`
`68`	`71`	`return c.chopClient.ClickhouseV1().ClickHouseInstallations(namespace).Get(ctx, name, controller.NewGetOptions())`
`69`	`72`	`}`
`70`	`73`
`71`	`74`	`func (c CR) getCM(ctx context.Context, chi api.ICustomResource) (core.ConfigMap, error) {`
	`75`	`+ ctx = k8sCtx(ctx)`
`72`	`76`	`return NewConfigMap(c.kubeClient).Get(ctx, c.buildCMNamespace(chi), c.buildCMName(chi))`
`73`	`77`	`}`
`74`	`78`
`@@ -99,7 +103,7 @@ func (c CR) buildCR(chi api.ClickHouseInstallation, cm core.ConfigMap) api.C`
`99`	`103`	`// StatusUpdate updates CR object's Status`
`100`	`104`	`func (c *CR) StatusUpdate(ctx context.Context, cr api.ICustomResource, opts commonTypes.UpdateStatusOptions) error {`
`101`	`105`	`if util.IsContextDone(ctx) {`
`102`		`- log.V(2).Info("task is done")`
	`106`	`+ log.V(1).Info("Reconcile is aborted. cr: %s ", cr.GetName())`
`103`	`107`	`return nil`
`104`	`108`	`}`
`105`	`109`
`@@ -130,7 +134,7 @@ func (c *CR) statusUpdateRetry(ctx context.Context, cr api.ICustomResource, opts`
`130`	`134`	`// statusUpdateProcess updates CR object's Status`
`131`	`135`	`func (c *CR) statusUpdateProcess(ctx context.Context, icr api.ICustomResource, opts commonTypes.UpdateStatusOptions) error {`
`132`	`136`	`if util.IsContextDone(ctx) {`
`133`		`- log.V(2).Info("task is done")`
	`137`	`+ log.V(1).Info("Reconcile is aborted. cr: %s ", icr.GetName())`
`134`	`138`	`return nil`
`135`	`139`	`}`
`136`	`140`
Original file line number	Diff line number	Diff line change
`@@ -32,9 +32,11 @@ func NewDeployment(kubeClient kube.Interface) *Deployment {`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`func (c Deployment) Get(namespace, name string) (apps.Deployment, error) {`
`35`		`- return c.kubeClient.AppsV1().Deployments(namespace).Get(controller.NewContext(), name, controller.NewGetOptions())`
	`35`	`+ ctx := k8sCtx(controller.NewContext())`
	`36`	`+ return c.kubeClient.AppsV1().Deployments(namespace).Get(ctx, name, controller.NewGetOptions())`
`36`	`37`	`}`
`37`	`38`
`38`	`39`	`func (c Deployment) Update(deployment apps.Deployment) (*apps.Deployment, error) {`
`39`		`- return c.kubeClient.AppsV1().Deployments(deployment.Namespace).Update(controller.NewContext(), deployment, controller.NewUpdateOptions())`
	`40`	`+ ctx := k8sCtx(controller.NewContext())`
	`41`	`+ return c.kubeClient.AppsV1().Deployments(deployment.Namespace).Update(ctx, deployment, controller.NewUpdateOptions())`
`40`	`42`	`}`
Original file line number	Diff line number	Diff line change
`@@ -34,5 +34,6 @@ func NewEvent(kubeClient kube.Interface) *Event {`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`func (c Event) Create(ctx context.Context, event core.Event) (*core.Event, error) {`
	`37`	`+ ctx = k8sCtx(ctx)`
`37`	`38`	`return c.kubeClient.CoreV1().Events(event.Namespace).Create(ctx, event, controller.NewCreateOptions())`
`38`	`39`	`}`
Original file line number	Diff line number	Diff line change
`@@ -39,18 +39,22 @@ func NewPDB(kubeClient kube.Interface) *PDB {`
`39`	`39`	`}`
`40`	`40`
`41`	`41`	`func (c PDB) Create(ctx context.Context, pdb policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error) {`
	`42`	`+ ctx = k8sCtx(ctx)`
`42`	`43`	`return c.kubeClient.PolicyV1().PodDisruptionBudgets(pdb.Namespace).Create(ctx, pdb, controller.NewCreateOptions())`
`43`	`44`	`}`
`44`	`45`
`45`	`46`	`func (c PDB) Get(ctx context.Context, namespace, name string) (policy.PodDisruptionBudget, error) {`
	`47`	`+ ctx = k8sCtx(ctx)`
`46`	`48`	`return c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).Get(ctx, name, controller.NewGetOptions())`
`47`	`49`	`}`
`48`	`50`
`49`	`51`	`func (c PDB) Update(ctx context.Context, pdb policy.PodDisruptionBudget) (*policy.PodDisruptionBudget, error) {`
	`52`	`+ ctx = k8sCtx(ctx)`
`50`	`53`	`return c.kubeClient.PolicyV1().PodDisruptionBudgets(pdb.Namespace).Update(ctx, pdb, controller.NewUpdateOptions())`
`51`	`54`	`}`
`52`	`55`
`53`	`56`	`func (c *PDB) Delete(ctx context.Context, namespace, name string) error {`
	`57`	`+ ctx = k8sCtx(ctx)`
`54`	`58`	`c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).Delete(ctx, name, controller.NewDeleteOptions())`
`55`	`59`	`return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).`
`56`	`60`	`WithOptions(poller.NewOptions().FromConfig(chop.Config())).`
`@@ -63,6 +67,7 @@ func (c *PDB) Delete(ctx context.Context, namespace, name string) error {`
`63`	`67`	`}`
`64`	`68`
`65`	`69`	`func (c *PDB) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]policy.PodDisruptionBudget, error) {`
	`70`	`+ ctx = k8sCtx(ctx)`
`66`	`71`	`list, err := c.kubeClient.PolicyV1().PodDisruptionBudgets(namespace).List(ctx, opts)`
`67`	`72`	`if err != nil {`
`68`	`73`	`return nil, err`
Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,8 @@ func (c Pod) Get(params ...any) (core.Pod, error) {`
`65`	`65`	`default:`
`66`	`66`	`panic(any("incorrect number or params"))`
`67`	`67`	`}`
`68`		`- return c.kubeClient.CoreV1().Pods(namespace).Get(controller.NewContext(), name, controller.NewGetOptions())`
	`68`	`+ ctx := k8sCtx(controller.NewContext())`
	`69`	`+ return c.kubeClient.CoreV1().Pods(namespace).Get(ctx, name, controller.NewGetOptions())`
`69`	`70`	`}`
`70`	`71`
`71`	`72`	`func (c *Pod) GetRestartCounters(params ...any) (map[string]int, error) {`
`@@ -93,6 +94,7 @@ func (c Pod) GetAll(obj any) []core.Pod {`
`93`	`94`	`}`
`94`	`95`
`95`	`96`	`func (c Pod) Update(ctx context.Context, pod core.Pod) (*core.Pod, error) {`
	`97`	`+ ctx = k8sCtx(ctx)`
`96`	`98`	`return c.kubeClient.CoreV1().Pods(pod.GetNamespace()).Update(ctx, pod, controller.NewUpdateOptions())`
`97`	`99`	`}`
`98`	`100`
`@@ -118,5 +120,6 @@ func (c Pod) getPod(host api.Host) (pods []*core.Pod) {`
`118`	`120`	`}`
`119`	`121`
`120`	`122`	`func (c *Pod) Delete(ctx context.Context, namespace, name string) error {`
	`123`	`+ ctx = k8sCtx(ctx)`
`121`	`124`	`return c.kubeClient.CoreV1().Pods(namespace).Delete(ctx, name, controller.NewDeleteOptions())`
`122`	`125`	`}`
Original file line number	Diff line number	Diff line change
`@@ -38,22 +38,27 @@ func NewPVC(kubeClient kube.Interface) *PVC {`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`func (c PVC) Create(ctx context.Context, pvc core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error) {`
	`41`	`+ ctx = k8sCtx(ctx)`
`41`	`42`	`return c.kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace).Create(ctx, pvc, controller.NewCreateOptions())`
`42`	`43`	`}`
`43`	`44`
`44`	`45`	`func (c PVC) Get(ctx context.Context, namespace, name string) (core.PersistentVolumeClaim, error) {`
	`46`	`+ ctx = k8sCtx(ctx)`
`45`	`47`	`return c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).Get(ctx, name, controller.NewGetOptions())`
`46`	`48`	`}`
`47`	`49`
`48`	`50`	`func (c PVC) Update(ctx context.Context, pvc core.PersistentVolumeClaim) (*core.PersistentVolumeClaim, error) {`
	`51`	`+ ctx = k8sCtx(ctx)`
`49`	`52`	`return c.kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace).Update(ctx, pvc, controller.NewUpdateOptions())`
`50`	`53`	`}`
`51`	`54`
`52`	`55`	`func (c *PVC) Delete(ctx context.Context, namespace, name string) error {`
	`56`	`+ ctx = k8sCtx(ctx)`
`53`	`57`	`return c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).Delete(ctx, name, controller.NewDeleteOptions())`
`54`	`58`	`}`
`55`	`59`
`56`	`60`	`func (c *PVC) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.PersistentVolumeClaim, error) {`
	`61`	`+ ctx = k8sCtx(ctx)`
`57`	`62`	`list, err := c.kubeClient.CoreV1().PersistentVolumeClaims(namespace).List(ctx, opts)`
`58`	`63`	`if err != nil {`
`59`	`64`	`return nil, err`
`@@ -65,6 +70,7 @@ func (c *PVC) List(ctx context.Context, namespace string, opts meta.ListOptions)`
`65`	`70`	`}`
`66`	`71`
`67`	`72`	`func (c PVC) ListForHost(ctx context.Context, host api.Host) (*core.PersistentVolumeClaimList, error) {`
	`73`	`+ ctx = k8sCtx(ctx)`
`68`	`74`	`return c.kubeClient.`
`69`	`75`	`CoreV1().`
`70`	`76`	`PersistentVolumeClaims(host.Runtime.Address.Namespace).`
Original file line number	Diff line number	Diff line change
`@@ -34,9 +34,11 @@ func NewReplicaSet(kubeClient kube.Interface) *ReplicaSet {`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`func (c ReplicaSet) Get(ctx context.Context, namespace, name string) (apps.ReplicaSet, error) {`
	`37`	`+ ctx = k8sCtx(ctx)`
`37`	`38`	`return c.kubeClient.AppsV1().ReplicaSets(namespace).Get(ctx, name, controller.NewGetOptions())`
`38`	`39`	`}`
`39`	`40`
`40`	`41`	`func (c ReplicaSet) Update(ctx context.Context, replicaSet apps.ReplicaSet) (*apps.ReplicaSet, error) {`
	`42`	`+ ctx = k8sCtx(ctx)`
`41`	`43`	`return c.kubeClient.AppsV1().ReplicaSets(replicaSet.Namespace).Update(ctx, replicaSet, controller.NewUpdateOptions())`
`42`	`44`	`}`
Original file line number	Diff line number	Diff line change
`@@ -64,18 +64,22 @@ func (c Secret) Get(ctx context.Context, params ...any) (core.Secret, error) {`
`64`	`64`	`namespace = typedObj.Runtime.Address.Namespace`
`65`	`65`	`}`
`66`	`66`	`}`
	`67`	`+ ctx = k8sCtx(ctx)`
`67`	`68`	`return c.kubeClient.CoreV1().Secrets(namespace).Get(ctx, name, controller.NewGetOptions())`
`68`	`69`	`}`
`69`	`70`
`70`	`71`	`func (c Secret) Create(ctx context.Context, svc core.Secret) (*core.Secret, error) {`
	`72`	`+ ctx = k8sCtx(ctx)`
`71`	`73`	`return c.kubeClient.CoreV1().Secrets(svc.Namespace).Create(ctx, svc, controller.NewCreateOptions())`
`72`	`74`	`}`
`73`	`75`
`74`	`76`	`func (c Secret) Update(ctx context.Context, svc core.Secret) (*core.Secret, error) {`
	`77`	`+ ctx = k8sCtx(ctx)`
`75`	`78`	`return c.kubeClient.CoreV1().Secrets(svc.Namespace).Update(ctx, svc, controller.NewUpdateOptions())`
`76`	`79`	`}`
`77`	`80`
`78`	`81`	`func (c *Secret) Delete(ctx context.Context, namespace, name string) error {`
	`82`	`+ ctx = k8sCtx(ctx)`
`79`	`83`	`c.kubeClient.CoreV1().Secrets(namespace).Delete(ctx, name, controller.NewDeleteOptions())`
`80`	`84`	`return poller.New(ctx, fmt.Sprintf("%s/%s", namespace, name)).`
`81`	`85`	`WithOptions(poller.NewOptions().FromConfig(chop.Config())).`
`@@ -89,6 +93,7 @@ func (c *Secret) Delete(ctx context.Context, namespace, name string) error {`
`89`	`93`	`}`
`90`	`94`
`91`	`95`	`func (c *Secret) List(ctx context.Context, namespace string, opts meta.ListOptions) ([]core.Secret, error) {`
	`96`	`+ ctx = k8sCtx(ctx)`
`92`	`97`	`list, err := c.kubeClient.CoreV1().Secrets(namespace).List(ctx, opts)`
`93`	`98`	`if err != nil {`
`94`	`99`	`return nil, err`