- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for informers (0.15 sec)
-
cni/pkg/nodeagent/informers.go
} pod := s.pods.Get(podName, podNamespace) if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() { kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced) go s.queue.Run(s.ctx.Done()) } func (s *InformerHandlers) GetAmbientPods() []*corev1.Pod { var pods []*corev1.Pod
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0)