diff --git a/go.mod b/go.mod index d5859ba6..6270dd78 100644 --- a/go.mod +++ b/go.mod @@ -25,13 +25,13 @@ require ( google.golang.org/protobuf v1.36.11 gopkg.in/h2non/gock.v1 v1.1.2 gopkg.in/inf.v0 v0.9.1 - k8s.io/api v0.34.2 - k8s.io/apimachinery v0.34.2 - k8s.io/client-go v0.34.2 - k8s.io/code-generator v0.34.2 - k8s.io/klog/v2 v2.130.1 - k8s.io/metrics v0.34.2 - k8s.io/utils v0.0.0-20250604170112-4c0f3b243397 + k8s.io/api v0.35.4 + k8s.io/apimachinery v0.35.4 + k8s.io/client-go v0.35.4 + k8s.io/code-generator v0.35.4 + k8s.io/klog/v2 v2.140.0 + k8s.io/metrics v0.35.4 + k8s.io/utils v0.0.0-20260319190234-28399d86e0b5 knative.dev/serving v0.46.6 ) @@ -75,7 +75,7 @@ require ( github.com/prometheus/client_model v0.6.2 // indirect github.com/prometheus/common v0.66.1 // indirect github.com/prometheus/procfs v0.17.0 // indirect - github.com/spf13/pflag v1.0.6 // indirect + github.com/spf13/pflag v1.0.9 // indirect github.com/x448/float16 v0.8.4 // indirect go.opentelemetry.io/auto/sdk v1.2.1 // indirect go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.67.0 // indirect @@ -83,7 +83,7 @@ require ( go.opentelemetry.io/otel/metric v1.43.0 // indirect go.opentelemetry.io/otel/trace v1.43.0 // indirect go.uber.org/multierr v1.11.0 // indirect - go.yaml.in/yaml/v2 v2.4.2 // indirect + go.yaml.in/yaml/v2 v2.4.3 // indirect go.yaml.in/yaml/v3 v3.0.4 // indirect golang.org/x/crypto v0.49.0 // indirect golang.org/x/mod v0.33.0 // indirect @@ -97,13 +97,13 @@ require ( gomodules.xyz/jsonpatch/v2 v2.5.0 // indirect google.golang.org/genproto/googleapis/api v0.0.0-20260406210006-6f92a3bedf2d // indirect google.golang.org/genproto/googleapis/rpc v0.0.0-20260406210006-6f92a3bedf2d // indirect - gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect + gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect - k8s.io/gengo/v2 v2.0.0-20250604051438-85fd79dbfd9f // indirect - k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b // indirect + k8s.io/gengo/v2 v2.0.0-20250922181213-ec3ebc5fd46b // indirect + k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912 // indirect knative.dev/networking v0.0.0-20250902160145-7dad473f6351 // indirect knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 // indirect - sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 // indirect + sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect sigs.k8s.io/randfill v1.0.0 // indirect sigs.k8s.io/structured-merge-diff/v6 v6.3.0 // indirect sigs.k8s.io/yaml v1.6.0 // indirect diff --git a/go.sum b/go.sum index 08d42d7e..39e7fb4d 100644 --- a/go.sum +++ b/go.sum @@ -132,6 +132,7 @@ github.com/oapi-codegen/runtime v1.0.0 h1:P4rqFX5fMFWqRzY9M/3YF9+aPSPPB06IzP2P7o github.com/oapi-codegen/runtime v1.0.0/go.mod h1:LmCUMQuPB4M/nLXilQXhHw+BLZdDb18B34OO356yJ/A= github.com/onsi/ginkgo/v2 v2.21.0 h1:7rg/4f3rB88pb5obDgNZrNHrQ4e6WpjonchcpuBRnZM= github.com/onsi/ginkgo/v2 v2.21.0/go.mod h1:7Du3c42kxCUegi0IImZ1wUQzMBVecgIHjR1C+NkhLQo= +github.com/onsi/ginkgo/v2 v2.27.2 h1:LzwLj0b89qtIy6SSASkzlNvX6WktqurSHwkk2ipF/Ns= github.com/onsi/gomega v1.35.1 h1:Cwbd75ZBPxFSuZ6T+rN/WCb/gOc6YgFBXLlZLhC7Ds4= github.com/onsi/gomega v1.35.1/go.mod h1:PvZbdDc8J6XJEpDK4HCuRBm8a6Fzp9/DmhC9C7yFlog= github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U= @@ -160,6 +161,8 @@ github.com/signalfx/signalfx-go v1.57.0 h1:Z+d/TJ/EVxkg46aP2lhAr5ft+EqwXb2nRmLvP github.com/signalfx/signalfx-go v1.57.0/go.mod h1:CHt+/W1qd62tXxNqG7ZUB9pEsEAOD6tuvdlyDNIOO1s= github.com/spf13/pflag v1.0.6 h1:jFzHGLGAlb3ruxLB8MhbI6A8+AQX/2eW4qeyNZXNp2o= github.com/spf13/pflag v1.0.6/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= +github.com/spf13/pflag v1.0.9 h1:9exaQaMOCwffKiiiYk6/BndUBv+iRViNW+4lEMi0PvY= +github.com/spf13/pflag v1.0.9/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= github.com/spkg/bom v0.0.0-20160624110644-59b7046e48ad/go.mod h1:qLr4V1qq6nMqFKkMo8ZTx3f+BZEkzsRUY10Xsm2mwU0= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY= @@ -198,6 +201,8 @@ go.uber.org/zap v1.27.1 h1:08RqriUEv8+ArZRYSTXy1LeBScaMpVSTBhCeaZYfMYc= go.uber.org/zap v1.27.1/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E= go.yaml.in/yaml/v2 v2.4.2 h1:DzmwEr2rDGHl7lsFgAHxmNz/1NlQ7xLIrlN2h5d1eGI= go.yaml.in/yaml/v2 v2.4.2/go.mod h1:081UH+NErpNdqlCXm3TtEran0rJZGxAYx9hb/ELlsPU= +go.yaml.in/yaml/v2 v2.4.3 h1:6gvOSjQoTB3vt1l+CU+tSyi/HOjfOjRLJ4YwYZGwRO0= +go.yaml.in/yaml/v2 v2.4.3/go.mod h1:zSxWcmIDjOzPXpjlTTbAsKokqkDNAVtZO0WOMiT90s8= go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc= go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= @@ -266,6 +271,8 @@ gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntN gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= gopkg.in/evanphx/json-patch.v4 v4.12.0 h1:n6jtcsulIzXPJaxegRbvFNNrZDjbij7ny3gmSPG+6V4= gopkg.in/evanphx/json-patch.v4 v4.12.0/go.mod h1:p8EYWUEYMpynmqDbY58zCKCFZw8pRWMG4EsWvDvM72M= +gopkg.in/evanphx/json-patch.v4 v4.13.0 h1:czT3CmqEaQ1aanPc5SdlgQrrEIb8w/wwCvWWnfEbYzo= +gopkg.in/evanphx/json-patch.v4 v4.13.0/go.mod h1:p8EYWUEYMpynmqDbY58zCKCFZw8pRWMG4EsWvDvM72M= gopkg.in/h2non/gock.v1 v1.1.2 h1:jBbHXgGBK/AoPVfJh5x4r/WxIrElvbLel8TCZkkZJoY= gopkg.in/h2non/gock.v1 v1.1.2/go.mod h1:n7UGz/ckNChHiK05rDoiC4MYSunEC/lyaUm2WWaDva0= gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc= @@ -277,22 +284,43 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= k8s.io/api v0.34.2 h1:fsSUNZhV+bnL6Aqrp6O7lMTy6o5x2C4XLjnh//8SLYY= k8s.io/api v0.34.2/go.mod h1:MMBPaWlED2a8w4RSeanD76f7opUoypY8TFYkSM+3XHw= +k8s.io/api v0.35.4 h1:P7nFYKl5vo9AGUp1Z+Pmd3p2tA7bX2wbFWCvDeRv988= +k8s.io/api v0.35.4/go.mod h1:yl4lqySWOgYJJf9RERXKUwE9g2y+CkuwG+xmcOK8wXU= k8s.io/apimachinery v0.34.2 h1:zQ12Uk3eMHPxrsbUJgNF8bTauTVR2WgqJsTmwTE/NW4= k8s.io/apimachinery v0.34.2/go.mod h1:/GwIlEcWuTX9zKIg2mbw0LRFIsXwrfoVxn+ef0X13lw= +k8s.io/apimachinery v0.35.4 h1:xtdom9RG7e+yDp71uoXoJDWEE2eOiHgeO4GdBzwWpds= +k8s.io/apimachinery v0.35.4/go.mod h1:NNi1taPOpep0jOj+oRha3mBJPqvi0hGdaV8TCqGQ+cc= k8s.io/client-go v0.34.2 h1:Co6XiknN+uUZqiddlfAjT68184/37PS4QAzYvQvDR8M= k8s.io/client-go v0.34.2/go.mod h1:2VYDl1XXJsdcAxw7BenFslRQX28Dxz91U9MWKjX97fE= +k8s.io/client-go v0.35.4 h1:DN6fyaGuzK64UvnKO5fOA6ymSjvfGAnCAHAR0C66kD8= +k8s.io/client-go v0.35.4/go.mod h1:2Pg9WpsS4NeOpoYTfHHfMxBG8zFMSAUi4O/qoiJC3nY= k8s.io/code-generator v0.34.2 h1:9bG6jTxmsU3HXE5BNYJTC8AZ1D6hVVfkm8yYSkdkGY0= k8s.io/code-generator v0.34.2/go.mod h1:dnDDEd6S/z4uZ+PG1aE58ySCi/lR4+qT3a4DddE4/2I= +k8s.io/code-generator v0.35.4 h1:i0FfiXAeUMBlHarjVk5ZWf6Wjsg3YJpNYmOg0nPk6r4= +k8s.io/code-generator v0.35.4/go.mod h1:rwLDdemFgPK6dGlLFHPUieyekgAlV1x8IVafjAy/ELA= k8s.io/gengo/v2 v2.0.0-20250604051438-85fd79dbfd9f h1:SLb+kxmzfA87x4E4brQzB33VBbT2+x7Zq9ROIHmGn9Q= k8s.io/gengo/v2 v2.0.0-20250604051438-85fd79dbfd9f/go.mod h1:EJykeLsmFC60UQbYJezXkEsG2FLrt0GPNkU5iK5GWxU= +k8s.io/gengo/v2 v2.0.0-20250922181213-ec3ebc5fd46b h1:gMplByicHV/TJBizHd9aVEsTYoJBnnUAT5MHlTkbjhQ= +k8s.io/gengo/v2 v2.0.0-20250922181213-ec3ebc5fd46b/go.mod h1:CgujABENc3KuTrcsdpGmrrASjtQsWCT7R99mEV4U/fM= +k8s.io/klog v1.0.0 h1:Pt+yjF5aB1xDSVbau4VsWe+dQNzA0qv1LlXdC2dF6Q8= k8s.io/klog/v2 v2.130.1 h1:n9Xl7H1Xvksem4KFG4PYbdQCQxqc/tTUyrgXaOhHSzk= k8s.io/klog/v2 v2.130.1/go.mod h1:3Jpz1GvMt720eyJH1ckRHK1EDfpxISzJ7I9OYgaDtPE= +k8s.io/klog/v2 v2.140.0 h1:Tf+J3AH7xnUzZyVVXhTgGhEKnFqye14aadWv7bzXdzc= +k8s.io/klog/v2 v2.140.0/go.mod h1:o+/RWfJ6PwpnFn7OyAG3QnO47BFsymfEfrz6XyYSSp0= k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b h1:MloQ9/bdJyIu9lb1PzujOPolHyvO06MXG5TUIj2mNAA= k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b/go.mod h1:UZ2yyWbFTpuhSbFhv24aGNOdoRdJZgsIObGBUaYVsts= +k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912 h1:Y3gxNAuB0OBLImH611+UDZcmKS3g6CthxToOb37KgwE= +k8s.io/kube-openapi v0.0.0-20250910181357-589584f1c912/go.mod h1:kdmbQkyfwUagLfXIad1y2TdrjPFWp2Q89B3qkRwf/pQ= k8s.io/metrics v0.34.2 h1:zao91FNDVPRGIiHLO2vqqe21zZVPien1goyzn0hsz90= k8s.io/metrics v0.34.2/go.mod h1:Ydulln+8uZZctUM8yrUQX4rfq/Ay6UzsuXf24QJ37Vc= +k8s.io/metrics v0.35.4 h1:KFo3xFe5rzLDarHLNjZB0J1g1c5fvl6A5Kk/8KzIwOA= +k8s.io/metrics v0.35.4/go.mod h1:5DO36o9esGC1VXylSpqJWmwhoopS/erADQcACz1tN3s= k8s.io/utils v0.0.0-20250604170112-4c0f3b243397 h1:hwvWFiBzdWw1FhfY1FooPn3kzWuJ8tmbZBHi4zVsl1Y= k8s.io/utils v0.0.0-20250604170112-4c0f3b243397/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0= +k8s.io/utils v0.0.0-20251002143259-bc988d571ff4 h1:SjGebBtkBqHFOli+05xYbK8YF1Dzkbzn+gDM4X9T4Ck= +k8s.io/utils v0.0.0-20251002143259-bc988d571ff4/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0= +k8s.io/utils v0.0.0-20260319190234-28399d86e0b5 h1:kBawHLSnx/mYHmRnNUf9d4CpjREbeZuxoSGOX/J+aYM= +k8s.io/utils v0.0.0-20260319190234-28399d86e0b5/go.mod h1:xDxuJ0whA3d0I4mf/C4ppKHxXynQ+fxnkmQH0vTHnuk= knative.dev/networking v0.0.0-20250902160145-7dad473f6351 h1:Gv/UqbN0AK+ORoT5e2Kg+3+uMW/y9CCdhpXKxYaVV6k= knative.dev/networking v0.0.0-20250902160145-7dad473f6351/go.mod h1:P/fAhhVDgmLt1ugFX8vBvdSDiUOw2P4SGcjbzoZ02Xw= knative.dev/pkg v0.0.0-20250909011231-077dcf0d00e8 h1:n0BMHXIem9MyDkK4vfA4Vzdxaf1e+EeLJ6k+8exCjjI= @@ -301,6 +329,8 @@ knative.dev/serving v0.46.6 h1:jmVF560qnepNBG69VEbNRtknGFwZtGEyR1QSlNuoKmk= knative.dev/serving v0.46.6/go.mod h1:mY7uXQo49PnxxM6UJWfnSAi6OqFEPM03dpWc8xsH3+I= sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 h1:gBQPwqORJ8d8/YNZWEjoZs7npUVDpVXUUOFfW6CgAqE= sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg= +sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 h1:IpInykpT6ceI+QxKBbEflcR5EXP7sU1kvOlxwZh5txg= +sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg= sigs.k8s.io/randfill v1.0.0 h1:JfjMILfT8A6RbawdsK2JXGBR5AQVfd+9TbzrlneTyrU= sigs.k8s.io/randfill v1.0.0/go.mod h1:XeLlZ/jmk4i1HRopwe7/aU3H5n1zNUcX6TM94b3QxOY= sigs.k8s.io/structured-merge-diff/v6 v6.3.0 h1:jTijUJbW353oVOd9oTlifJqOGEkUw2jB/fXCbTiQEco= diff --git a/pkg/client/clientset/versioned/fake/clientset_generated.go b/pkg/client/clientset/versioned/fake/clientset_generated.go index 9df186ff..d6da85dc 100644 --- a/pkg/client/clientset/versioned/fake/clientset_generated.go +++ b/pkg/client/clientset/versioned/fake/clientset_generated.go @@ -64,10 +64,6 @@ import ( // It's backed by a very simple object tracker that processes creates, updates and deletions as-is, // without applying any field management, validations and/or defaults. It shouldn't be considered a replacement // for a real clientset and is mostly useful in simple unit tests. -// -// DEPRECATED: NewClientset replaces this with support for field management, which significantly improves -// server side apply testing. NewClientset is only available when apply configurations are generated (e.g. -// via --with-applyconfig). func NewSimpleClientset(objects ...runtime.Object) *Clientset { o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) for _, obj := range objects { @@ -81,8 +77,8 @@ func NewSimpleClientset(objects ...runtime.Object) *Clientset { cs.AddReactor("*", "*", testing.ObjectReaction(o)) cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { var opts metav1.ListOptions - if watchActcion, ok := action.(testing.WatchActionImpl); ok { - opts = watchActcion.ListOptions + if watchAction, ok := action.(testing.WatchActionImpl); ok { + opts = watchAction.ListOptions } gvr := action.GetResource() ns := action.GetNamespace() @@ -113,6 +109,17 @@ func (c *Clientset) Tracker() testing.ObjectTracker { return c.tracker } +// IsWatchListSemanticsSupported informs the reflector that this client +// doesn't support WatchList semantics. +// +// This is a synthetic method whose sole purpose is to satisfy the optional +// interface check performed by the reflector. +// Returning true signals that WatchList can NOT be used. +// No additional logic is implemented here. +func (c *Clientset) IsWatchListSemanticsUnSupported() bool { + return true +} + var ( _ clientset.Interface = &Clientset{} _ testing.FakeClient = &Clientset{} diff --git a/pkg/client/informers/externalversions/apisix/v2/apisixroute.go b/pkg/client/informers/externalversions/apisix/v2/apisixroute.go index 934fc22c..49c5dd10 100644 --- a/pkg/client/informers/externalversions/apisix/v2/apisixroute.go +++ b/pkg/client/informers/externalversions/apisix/v2/apisixroute.go @@ -57,7 +57,7 @@ func NewApisixRouteInformer(client versioned.Interface, namespace string, resync // one. This reduces memory footprint and number of connections to the server. func NewFilteredApisixRouteInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredApisixRouteInformer(client versioned.Interface, namespace string } return client.ApisixV2().ApisixRoutes(namespace).Watch(ctx, options) }, - }, + }, client), &apisapisixv2.ApisixRoute{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta1/mesh.go b/pkg/client/informers/externalversions/appmesh/v1beta1/mesh.go index 9ea88d7b..80aca072 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta1/mesh.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta1/mesh.go @@ -56,7 +56,7 @@ func NewMeshInformer(client versioned.Interface, resyncPeriod time.Duration, ind // one. This reduces memory footprint and number of connections to the server. func NewFilteredMeshInformer(client versioned.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -81,7 +81,7 @@ func NewFilteredMeshInformer(client versioned.Interface, resyncPeriod time.Durat } return client.AppmeshV1beta1().Meshes().Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta1.Mesh{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta1/virtualnode.go b/pkg/client/informers/externalversions/appmesh/v1beta1/virtualnode.go index 7b75249a..91802324 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta1/virtualnode.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta1/virtualnode.go @@ -57,7 +57,7 @@ func NewVirtualNodeInformer(client versioned.Interface, namespace string, resync // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualNodeInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualNodeInformer(client versioned.Interface, namespace string } return client.AppmeshV1beta1().VirtualNodes(namespace).Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta1.VirtualNode{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta1/virtualservice.go b/pkg/client/informers/externalversions/appmesh/v1beta1/virtualservice.go index 7ffd923d..a68abf48 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta1/virtualservice.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta1/virtualservice.go @@ -57,7 +57,7 @@ func NewVirtualServiceInformer(client versioned.Interface, namespace string, res // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace str } return client.AppmeshV1beta1().VirtualServices(namespace).Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta1.VirtualService{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualnode.go b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualnode.go index 98e5d698..8f1edff6 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualnode.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualnode.go @@ -57,7 +57,7 @@ func NewVirtualNodeInformer(client versioned.Interface, namespace string, resync // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualNodeInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualNodeInformer(client versioned.Interface, namespace string } return client.AppmeshV1beta2().VirtualNodes(namespace).Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta2.VirtualNode{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualrouter.go b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualrouter.go index 2d72e92e..926daa0a 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualrouter.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualrouter.go @@ -57,7 +57,7 @@ func NewVirtualRouterInformer(client versioned.Interface, namespace string, resy // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualRouterInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualRouterInformer(client versioned.Interface, namespace stri } return client.AppmeshV1beta2().VirtualRouters(namespace).Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta2.VirtualRouter{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualservice.go b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualservice.go index 2ac73a71..0c4c71ba 100644 --- a/pkg/client/informers/externalversions/appmesh/v1beta2/virtualservice.go +++ b/pkg/client/informers/externalversions/appmesh/v1beta2/virtualservice.go @@ -57,7 +57,7 @@ func NewVirtualServiceInformer(client versioned.Interface, namespace string, res // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace str } return client.AppmeshV1beta2().VirtualServices(namespace).Watch(ctx, options) }, - }, + }, client), &apisappmeshv1beta2.VirtualService{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/factory.go b/pkg/client/informers/externalversions/factory.go index bce8238e..dfe82523 100644 --- a/pkg/client/informers/externalversions/factory.go +++ b/pkg/client/informers/externalversions/factory.go @@ -108,6 +108,7 @@ func NewSharedInformerFactory(client versioned.Interface, defaultResync time.Dur // NewFilteredSharedInformerFactory constructs a new instance of sharedInformerFactory. // Listers obtained via this SharedInformerFactory will be subject to the same filters // as specified here. +// // Deprecated: Please use NewSharedInformerFactoryWithOptions instead func NewFilteredSharedInformerFactory(client versioned.Interface, defaultResync time.Duration, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) SharedInformerFactory { return NewSharedInformerFactoryWithOptions(client, defaultResync, WithNamespace(namespace), WithTweakListOptions(tweakListOptions)) @@ -215,7 +216,7 @@ func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internal // // It is typically used like this: // -// ctx, cancel := context.Background() +// ctx, cancel := context.WithCancel(context.Background()) // defer cancel() // factory := NewSharedInformerFactory(client, resyncPeriod) // defer factory.WaitForStop() // Returns immediately if nothing was started. diff --git a/pkg/client/informers/externalversions/flagger/v1beta1/alertprovider.go b/pkg/client/informers/externalversions/flagger/v1beta1/alertprovider.go index d1841c1e..b7ce25ee 100644 --- a/pkg/client/informers/externalversions/flagger/v1beta1/alertprovider.go +++ b/pkg/client/informers/externalversions/flagger/v1beta1/alertprovider.go @@ -57,7 +57,7 @@ func NewAlertProviderInformer(client versioned.Interface, namespace string, resy // one. This reduces memory footprint and number of connections to the server. func NewFilteredAlertProviderInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredAlertProviderInformer(client versioned.Interface, namespace stri } return client.FlaggerV1beta1().AlertProviders(namespace).Watch(ctx, options) }, - }, + }, client), &apisflaggerv1beta1.AlertProvider{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/flagger/v1beta1/canary.go b/pkg/client/informers/externalversions/flagger/v1beta1/canary.go index 544c0ed8..a54934bf 100644 --- a/pkg/client/informers/externalversions/flagger/v1beta1/canary.go +++ b/pkg/client/informers/externalversions/flagger/v1beta1/canary.go @@ -57,7 +57,7 @@ func NewCanaryInformer(client versioned.Interface, namespace string, resyncPerio // one. This reduces memory footprint and number of connections to the server. func NewFilteredCanaryInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredCanaryInformer(client versioned.Interface, namespace string, res } return client.FlaggerV1beta1().Canaries(namespace).Watch(ctx, options) }, - }, + }, client), &apisflaggerv1beta1.Canary{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/flagger/v1beta1/metrictemplate.go b/pkg/client/informers/externalversions/flagger/v1beta1/metrictemplate.go index 627ab4be..1bd3a87c 100644 --- a/pkg/client/informers/externalversions/flagger/v1beta1/metrictemplate.go +++ b/pkg/client/informers/externalversions/flagger/v1beta1/metrictemplate.go @@ -57,7 +57,7 @@ func NewMetricTemplateInformer(client versioned.Interface, namespace string, res // one. This reduces memory footprint and number of connections to the server. func NewFilteredMetricTemplateInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredMetricTemplateInformer(client versioned.Interface, namespace str } return client.FlaggerV1beta1().MetricTemplates(namespace).Watch(ctx, options) }, - }, + }, client), &apisflaggerv1beta1.MetricTemplate{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/gatewayapi/v1/httproute.go b/pkg/client/informers/externalversions/gatewayapi/v1/httproute.go index fa399f44..2e853ecd 100644 --- a/pkg/client/informers/externalversions/gatewayapi/v1/httproute.go +++ b/pkg/client/informers/externalversions/gatewayapi/v1/httproute.go @@ -57,7 +57,7 @@ func NewHTTPRouteInformer(client versioned.Interface, namespace string, resyncPe // one. This reduces memory footprint and number of connections to the server. func NewFilteredHTTPRouteInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredHTTPRouteInformer(client versioned.Interface, namespace string, } return client.GatewayapiV1().HTTPRoutes(namespace).Watch(ctx, options) }, - }, + }, client), &apisgatewayapiv1.HTTPRoute{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/gatewayapi/v1beta1/httproute.go b/pkg/client/informers/externalversions/gatewayapi/v1beta1/httproute.go index 0ccec941..d2665811 100644 --- a/pkg/client/informers/externalversions/gatewayapi/v1beta1/httproute.go +++ b/pkg/client/informers/externalversions/gatewayapi/v1beta1/httproute.go @@ -57,7 +57,7 @@ func NewHTTPRouteInformer(client versioned.Interface, namespace string, resyncPe // one. This reduces memory footprint and number of connections to the server. func NewFilteredHTTPRouteInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredHTTPRouteInformer(client versioned.Interface, namespace string, } return client.GatewayapiV1beta1().HTTPRoutes(namespace).Watch(ctx, options) }, - }, + }, client), &apisgatewayapiv1beta1.HTTPRoute{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/gloo/v1/upstream.go b/pkg/client/informers/externalversions/gloo/v1/upstream.go index be877123..88a4b48e 100644 --- a/pkg/client/informers/externalversions/gloo/v1/upstream.go +++ b/pkg/client/informers/externalversions/gloo/v1/upstream.go @@ -57,7 +57,7 @@ func NewUpstreamInformer(client versioned.Interface, namespace string, resyncPer // one. This reduces memory footprint and number of connections to the server. func NewFilteredUpstreamInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredUpstreamInformer(client versioned.Interface, namespace string, r } return client.GlooV1().Upstreams(namespace).Watch(ctx, options) }, - }, + }, client), &apisgloov1.Upstream{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/gloogateway/v1/routetable.go b/pkg/client/informers/externalversions/gloogateway/v1/routetable.go index 43018fe8..dc821bdd 100644 --- a/pkg/client/informers/externalversions/gloogateway/v1/routetable.go +++ b/pkg/client/informers/externalversions/gloogateway/v1/routetable.go @@ -57,7 +57,7 @@ func NewRouteTableInformer(client versioned.Interface, namespace string, resyncP // one. This reduces memory footprint and number of connections to the server. func NewFilteredRouteTableInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredRouteTableInformer(client versioned.Interface, namespace string, } return client.GatewayV1().RouteTables(namespace).Watch(ctx, options) }, - }, + }, client), &apisgloogatewayv1.RouteTable{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/istio/v1beta1/destinationrule.go b/pkg/client/informers/externalversions/istio/v1beta1/destinationrule.go index 8c7a2c5e..f10ab274 100644 --- a/pkg/client/informers/externalversions/istio/v1beta1/destinationrule.go +++ b/pkg/client/informers/externalversions/istio/v1beta1/destinationrule.go @@ -57,7 +57,7 @@ func NewDestinationRuleInformer(client versioned.Interface, namespace string, re // one. This reduces memory footprint and number of connections to the server. func NewFilteredDestinationRuleInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredDestinationRuleInformer(client versioned.Interface, namespace st } return client.NetworkingV1beta1().DestinationRules(namespace).Watch(ctx, options) }, - }, + }, client), &apisistiov1beta1.DestinationRule{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/istio/v1beta1/virtualservice.go b/pkg/client/informers/externalversions/istio/v1beta1/virtualservice.go index c16944ac..0e5e1736 100644 --- a/pkg/client/informers/externalversions/istio/v1beta1/virtualservice.go +++ b/pkg/client/informers/externalversions/istio/v1beta1/virtualservice.go @@ -57,7 +57,7 @@ func NewVirtualServiceInformer(client versioned.Interface, namespace string, res // one. This reduces memory footprint and number of connections to the server. func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredVirtualServiceInformer(client versioned.Interface, namespace str } return client.NetworkingV1beta1().VirtualServices(namespace).Watch(ctx, options) }, - }, + }, client), &apisistiov1beta1.VirtualService{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/keda/v1alpha1/scaledobject.go b/pkg/client/informers/externalversions/keda/v1alpha1/scaledobject.go index ef594601..a0481fab 100644 --- a/pkg/client/informers/externalversions/keda/v1alpha1/scaledobject.go +++ b/pkg/client/informers/externalversions/keda/v1alpha1/scaledobject.go @@ -57,7 +57,7 @@ func NewScaledObjectInformer(client versioned.Interface, namespace string, resyn // one. This reduces memory footprint and number of connections to the server. func NewFilteredScaledObjectInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredScaledObjectInformer(client versioned.Interface, namespace strin } return client.KedaV1alpha1().ScaledObjects(namespace).Watch(ctx, options) }, - }, + }, client), &apiskedav1alpha1.ScaledObject{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/kuma/v1alpha1/trafficroute.go b/pkg/client/informers/externalversions/kuma/v1alpha1/trafficroute.go index d5e5358c..d4f525dc 100644 --- a/pkg/client/informers/externalversions/kuma/v1alpha1/trafficroute.go +++ b/pkg/client/informers/externalversions/kuma/v1alpha1/trafficroute.go @@ -56,7 +56,7 @@ func NewTrafficRouteInformer(client versioned.Interface, resyncPeriod time.Durat // one. This reduces memory footprint and number of connections to the server. func NewFilteredTrafficRouteInformer(client versioned.Interface, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -81,7 +81,7 @@ func NewFilteredTrafficRouteInformer(client versioned.Interface, resyncPeriod ti } return client.KumaV1alpha1().TrafficRoutes().Watch(ctx, options) }, - }, + }, client), &apiskumav1alpha1.TrafficRoute{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/projectcontour/v1/httpproxy.go b/pkg/client/informers/externalversions/projectcontour/v1/httpproxy.go index 5b87fa15..b47166fb 100644 --- a/pkg/client/informers/externalversions/projectcontour/v1/httpproxy.go +++ b/pkg/client/informers/externalversions/projectcontour/v1/httpproxy.go @@ -57,7 +57,7 @@ func NewHTTPProxyInformer(client versioned.Interface, namespace string, resyncPe // one. This reduces memory footprint and number of connections to the server. func NewFilteredHTTPProxyInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredHTTPProxyInformer(client versioned.Interface, namespace string, } return client.ProjectcontourV1().HTTPProxies(namespace).Watch(ctx, options) }, - }, + }, client), &apisprojectcontourv1.HTTPProxy{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/smi/v1alpha1/trafficsplit.go b/pkg/client/informers/externalversions/smi/v1alpha1/trafficsplit.go index 25075bcc..76fa5d2f 100644 --- a/pkg/client/informers/externalversions/smi/v1alpha1/trafficsplit.go +++ b/pkg/client/informers/externalversions/smi/v1alpha1/trafficsplit.go @@ -57,7 +57,7 @@ func NewTrafficSplitInformer(client versioned.Interface, namespace string, resyn // one. This reduces memory footprint and number of connections to the server. func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace strin } return client.SplitV1alpha1().TrafficSplits(namespace).Watch(ctx, options) }, - }, + }, client), &apissmiv1alpha1.TrafficSplit{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/smi/v1alpha2/trafficsplit.go b/pkg/client/informers/externalversions/smi/v1alpha2/trafficsplit.go index 90d2a78f..963598b3 100644 --- a/pkg/client/informers/externalversions/smi/v1alpha2/trafficsplit.go +++ b/pkg/client/informers/externalversions/smi/v1alpha2/trafficsplit.go @@ -57,7 +57,7 @@ func NewTrafficSplitInformer(client versioned.Interface, namespace string, resyn // one. This reduces memory footprint and number of connections to the server. func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace strin } return client.SplitV1alpha2().TrafficSplits(namespace).Watch(ctx, options) }, - }, + }, client), &apissmiv1alpha2.TrafficSplit{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/smi/v1alpha3/trafficsplit.go b/pkg/client/informers/externalversions/smi/v1alpha3/trafficsplit.go index ac621a9c..2fd520ae 100644 --- a/pkg/client/informers/externalversions/smi/v1alpha3/trafficsplit.go +++ b/pkg/client/informers/externalversions/smi/v1alpha3/trafficsplit.go @@ -57,7 +57,7 @@ func NewTrafficSplitInformer(client versioned.Interface, namespace string, resyn // one. This reduces memory footprint and number of connections to the server. func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredTrafficSplitInformer(client versioned.Interface, namespace strin } return client.SplitV1alpha3().TrafficSplits(namespace).Watch(ctx, options) }, - }, + }, client), &apissmiv1alpha3.TrafficSplit{}, resyncPeriod, indexers, diff --git a/pkg/client/informers/externalversions/traefik/v1alpha1/traefikservice.go b/pkg/client/informers/externalversions/traefik/v1alpha1/traefikservice.go index 446aeaf1..3da24f49 100644 --- a/pkg/client/informers/externalversions/traefik/v1alpha1/traefikservice.go +++ b/pkg/client/informers/externalversions/traefik/v1alpha1/traefikservice.go @@ -57,7 +57,7 @@ func NewTraefikServiceInformer(client versioned.Interface, namespace string, res // one. This reduces memory footprint and number of connections to the server. func NewFilteredTraefikServiceInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { return cache.NewSharedIndexInformer( - &cache.ListWatch{ + cache.ToListWatcherWithWatchListSemantics(&cache.ListWatch{ ListFunc: func(options v1.ListOptions) (runtime.Object, error) { if tweakListOptions != nil { tweakListOptions(&options) @@ -82,7 +82,7 @@ func NewFilteredTraefikServiceInformer(client versioned.Interface, namespace str } return client.TraefikV1alpha1().TraefikServices(namespace).Watch(ctx, options) }, - }, + }, client), &apistraefikv1alpha1.TraefikService{}, resyncPeriod, indexers,