fix: deprecated Webhook Server & cache Namespace

This commit is contained in:
Ansh Garhewal 2024-07-21 12:46:47 +05:30
parent bfd9d3c60b
commit 9cfc490cd5
No known key found for this signature in database
1 changed files with 16 additions and 4 deletions

View File

@ -40,7 +40,10 @@ import (
utilruntime "k8s.io/apimachinery/pkg/util/runtime" utilruntime "k8s.io/apimachinery/pkg/util/runtime"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
clientgoscheme "k8s.io/client-go/kubernetes/scheme" clientgoscheme "k8s.io/client-go/kubernetes/scheme"
"sigs.k8s.io/controller-runtime/pkg/cache"
"sigs.k8s.io/controller-runtime/pkg/client/config" "sigs.k8s.io/controller-runtime/pkg/client/config"
"sigs.k8s.io/controller-runtime/pkg/metrics/server"
"sigs.k8s.io/controller-runtime/pkg/webhook"
// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.) // Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
// to ensure that exec-entrypoint and run can make use of them. // to ensure that exec-entrypoint and run can make use of them.
@ -126,14 +129,23 @@ func main() {
fatal(errors.Wrap(err, "failed to get config"), *debug) fatal(errors.Wrap(err, "failed to get config"), *debug)
} }
cacheNamespace := map[string]cache.Config{}
cacheNamespace[namespace] = cache.Config{}
mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{ mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
// MetricsBindAddress: fmt.Sprintf("%s:%d", metricsHost, metricsPort),
Metrics: server.Options{
BindAddress: fmt.Sprintf("%s:%d", metricsHost, metricsPort),
},
Scheme: scheme, Scheme: scheme,
MetricsBindAddress: fmt.Sprintf("%s:%d", metricsHost, metricsPort), // Port: 9443,
WebhookServer: webhook.NewServer(webhook.Options{
Port: 9443, Port: 9443,
}),
HealthProbeBindAddress: probeAddr, HealthProbeBindAddress: probeAddr,
LeaderElection: enableLeaderElection, LeaderElection: enableLeaderElection,
LeaderElectionID: "c674355f.jenkins.io", LeaderElectionID: "c674355f.jenkins.io",
Namespace: namespace, // Namespace: namespace,
Cache: cache.Options{DefaultNamespaces: cacheNamespace},
}) })
if err != nil { if err != nil {
fatal(errors.Wrap(err, "unable to start manager"), *debug) fatal(errors.Wrap(err, "unable to start manager"), *debug)