Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for informers (0.17 sec)

  1. 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)
Back to top