diff --git a/services/cm.go b/services/cm.go index ddc765c3f05386ccd50b62ebb263c1f2b2f7845e..e48a4230e2d754bd000438c9bc915a33224df322 100644 --- a/services/cm.go +++ b/services/cm.go @@ -18,6 +18,7 @@ import ( "k8s.io/kubernetes/pkg/controller/daemon" "k8s.io/kubernetes/pkg/controller/deployment" "k8s.io/kubernetes/pkg/controller/endpoint" + "k8s.io/kubernetes/pkg/controller/endpointslice" "k8s.io/kubernetes/pkg/controller/garbagecollector" "k8s.io/kubernetes/pkg/controller/namespace" "k8s.io/kubernetes/pkg/controller/nodelifecycle" @@ -231,6 +232,19 @@ var kubeControllerManager = &Unit{ 0, // batch duration ).Run(ctx, 1) + go endpointslice.NewController( + clients.Informer.Core().V1().Pods(), + clients.Informer.Core().V1().Services(), + clients.Informer.Core().V1().Nodes(), + clients.Informer.Discovery().V1().EndpointSlices(), + 100, // default + clients.Client, + 0, // batch duration + ).Run(1, ctx.Done()) + + // TODO maybe run the endpointslice mirroring controller if we ever create endpoints + // manually + ////////////////// /// Storage //////////////////