Function NewNonBlockingDiscoveryNamespacesFilter

pkg/kube/namespace/filter.go:124–134

NewNonBlockingDiscoveryNamespacesFilter creates the filter without blocking to wait on the initial sync. Use the returned ManualSyncWaiter to wait for the initial sync when desired.

(
	namespaces kclient.Client[*corev1.Namespace],
	mesh mesh.Watcher,
	stop <-chan struct{},
)

// NewNonBlockingDiscoveryNamespacesFilter creates the filter without blocking to wait on the initial sync.
// Use the returned ManualSyncWaiter to wait for the initial sync when desired.
func NewNonBlockingDiscoveryNamespacesFilter(
	namespaces kclient.Client[*corev1.Namespace],
	mesh mesh.Watcher,
	stop <-chan struct{},
) (kubetypes.DynamicObjectFilter, ManualSyncWaiter) {
	f := newDiscoveryNamespacesFilter(namespaces, mesh, stop, false)
	return f, func(stop <-chan struct{}) {
		kube.WaitForCacheSync("discovery filter", stop, namespaces.HasSynced)
		f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), false)
	}
}

func (d *discoveryNamespacesFilter) notifyHandlers(added sets.Set[string], removed sets.String) {
	// Clone handlers; we handle dynamic handlers so they can change after the filter has started.