diff --git a/cmd/event-logger/app/options.go b/cmd/event-logger/app/options.go index 20bf1e8a..d15f9101 100644 --- a/cmd/event-logger/app/options.go +++ b/cmd/event-logger/app/options.go @@ -110,7 +110,7 @@ func (o *Options) config(seedKubeAPIServerConfig *rest.Config, seedKubeClient *k for _, namespace := range o.SeedEventWatcher.Namespaces { config.SeedKubeInformerFactories = append(config.SeedKubeInformerFactories, - kubeinformers.NewFilteredSharedInformerFactory(shootKubeClient, shootKubeAPIServerConfig.Timeout, namespace, nil), + kubeinformers.NewFilteredSharedInformerFactory(seedKubeClient, shootKubeAPIServerConfig.Timeout, namespace, nil), ) } diff --git a/pkg/events/gardener_event_watcher.go b/pkg/events/gardener_event_watcher.go index 481c5533..7576a337 100644 --- a/pkg/events/gardener_event_watcher.go +++ b/pkg/events/gardener_event_watcher.go @@ -15,8 +15,6 @@ package events import ( - "fmt" - v1 "k8s.io/api/core/v1" kubeinformers "k8s.io/client-go/informers" ) @@ -35,7 +33,6 @@ type GardenerEventWatcher struct { func (e *GardenerEventWatcherConfig) New() *GardenerEventWatcher { for indx, namespace := range e.SeedEventWatcherConfig.Namespaces { - fmt.Println("**********MAKE SEED EVENT WATCHER FOR NAMESPACE: ", namespace, "*****************") _ = e.SeedKubeInformerFactories[indx].InformerFor(&v1.Event{}, NewEventInformerFuncForNamespace( "seed", @@ -45,7 +42,6 @@ func (e *GardenerEventWatcherConfig) New() *GardenerEventWatcher { } for indx, namespace := range e.ShootEventWatcherConfig.Namespaces { - fmt.Println("**********MAKE SHOOT EVENT WATCHER FOR NAMESPACE: ", namespace, "*****************") _ = e.ShootKubeInformerFactories[indx].InformerFor(&v1.Event{}, NewEventInformerFuncForNamespace( "shoot", diff --git a/pkg/events/options.go b/pkg/events/options.go index 933af4e2..b9cde534 100644 --- a/pkg/events/options.go +++ b/pkg/events/options.go @@ -25,7 +25,7 @@ import ( func (o *Options) Validate() []error { allErrors := []error{} - if o.Kubeconfig != "inClusterConfig" { + if o.Kubeconfig != "inClusterConfig" && o.Kubeconfig != "" { if _, err := os.Stat(o.Kubeconfig); err != nil { allErrors = append(allErrors, err) }