Unnecessary access to v1.Pod lead to timeout.

**What happened**:

my config:
```
        --source=service
        --service-type-filter=LoadBalancer
```

my k8s cluster has too many pods, and apiserver can NOT return in 60 seconds.

It will error at:
```
time="2024-12-16T12:43:02Z" level=info msg="Created Kubernetes client https://10.0.0.1:443"
time="2024-12-16T12:44:02Z" level=fatal msg="failed to sync *v1.Pod: context deadline exceeded"
```

**What you expected to happen**:

Because I specifiy `source=service` and `service-type-filter=LoadBalancer`, So it should NEVER accecss api to `v1.Pod`. 

But actually, `NewServiceSource` call `waitForCacheSync` which will get all pods regardless of `service-type-filter`.

https://github.com/kubernetes-sigs/external-dns/blob/2a45cc85a4981f8a843468eca49ae3fe36af3462/source/service.go#L67-L113

So it became timeout because of hard code time.

https://github.com/kubernetes-sigs/external-dns/blob/2a45cc85a4981f8a843468eca49ae3fe36af3462/source/source.go#L356

**How to reproduce it (as minimally and precisely as possible)**:

**Anything else we need to know?**:

**Environment**:
- External-DNS version (use `external-dns --version`): v0.14.2
- DNS provider: rfc2136
- Others:


** Releated issues**:
- https://github.com/kubernetes-sigs/external-dns/issues/3173
- https://github.com/kubernetes-sigs/external-dns/issues/3169

	func NewServiceSource(ctx context.Context, kubeClient kubernetes.Interface, namespace, annotationFilter string, fqdnTemplate string, combineFqdnAnnotation bool, compatibility string, publishInternal bool, publishHostIP bool, alwaysPublishNotReadyAddresses bool, serviceTypeFilter []string, ignoreHostnameAnnotation bool, labelSelector labels.Selector, resolveLoadBalancerHostname bool) (Source, error) {
	tmpl, err := parseTemplate(fqdnTemplate)
	if err != nil {
	return nil, err
	}

	// Use shared informers to listen for add/update/delete of services/pods/nodes in the specified namespace.
	// Set resync period to 0, to prevent processing when nothing has changed
	informerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(kubeClient, 0, kubeinformers.WithNamespace(namespace))
	serviceInformer := informerFactory.Core().V1().Services()
	endpointsInformer := informerFactory.Core().V1().Endpoints()
	podInformer := informerFactory.Core().V1().Pods()
	nodeInformer := informerFactory.Core().V1().Nodes()

	// Add default resource event handlers to properly initialize informer.
	serviceInformer.Informer().AddEventHandler(
	cache.ResourceEventHandlerFuncs{
	AddFunc: func(obj interface{}) {
	},
	},
	)
	endpointsInformer.Informer().AddEventHandler(
	cache.ResourceEventHandlerFuncs{
	AddFunc: func(obj interface{}) {
	},
	},
	)
	podInformer.Informer().AddEventHandler(
	cache.ResourceEventHandlerFuncs{
	AddFunc: func(obj interface{}) {
	},
	},
	)
	nodeInformer.Informer().AddEventHandler(
	cache.ResourceEventHandlerFuncs{
	AddFunc: func(obj interface{}) {
	},
	},
	)

	informerFactory.Start(ctx.Done())

	// wait for the local cache to be populated.
	if err := waitForCacheSync(context.Background(), informerFactory); err != nil {
	return nil, err
	}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Unnecessary access to v1.Pod lead to timeout. #4955

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Unnecessary access to v1.Pod lead to timeout. #4955

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions