@@ -29,15 +29,15 @@ import (
2929
3030// StatusTracker manages incremental status updates during reconciliation
3131type StatusTracker struct {
32- client client.Client
33- original * v1alpha1.Function
32+ k8sClient client.Client
33+ original * v1alpha1.Function
3434}
3535
3636// NewStatusTracker creates a new status tracker with a snapshot of the current function state
37- func NewStatusTracker (client client.Client , function * v1alpha1.Function ) * StatusTracker {
37+ func NewStatusTracker (k8sClient client.Client , function * v1alpha1.Function ) * StatusTracker {
3838 return & StatusTracker {
39- client : client ,
40- original : function .DeepCopy (),
39+ k8sClient : k8sClient ,
40+ original : function .DeepCopy (),
4141 }
4242}
4343
@@ -52,7 +52,7 @@ func (t *StatusTracker) Flush(ctx context.Context, current *v1alpha1.Function) e
5252 err := retry .RetryOnConflict (retry .DefaultRetry , func () error {
5353 // Get the latest version to ensure we have the most recent resourceVersion
5454 latest := & v1alpha1.Function {}
55- if err := t .client .Get (ctx , types.NamespacedName {
55+ if err := t .k8sClient .Get (ctx , types.NamespacedName {
5656 Name : current .Name ,
5757 Namespace : current .Namespace ,
5858 }, latest ); err != nil {
@@ -63,7 +63,7 @@ func (t *StatusTracker) Flush(ctx context.Context, current *v1alpha1.Function) e
6363 latest .Status = current .Status
6464
6565 // Attempt the update
66- return t .client .Status ().Update (ctx , latest )
66+ return t .k8sClient .Status ().Update (ctx , latest )
6767 })
6868
6969 if err != nil {
0 commit comments