[Question] Whether the k8s Headless service supports namespaces

[dagehuifei]

how to set namespace in k8s headless service registry and discovery ?

[dagehuifei]

// NewRegistry is used to initialize the Registry
func NewRegistry(clientSet *kubernetes.Clientset, namespace string) Registry {
informerFactory := informers.NewSharedInformerFactoryWithOptions(clientSet, time.Minute10, informers.WithNamespace(namespace))
podInformer := informerFactory.Core().V1().Pods().Informer()
podLister := informerFactory.Core().V1().Pods().Lister()
return &Registry{
clientSet: clientSet,
informerFactory: informerFactory,
podInformer: podInformer,
podLister: podLister,
stopCh: make(chan struct{}),
}
}