- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for PodRedirectionEnabled (0.17 sec)
-
cni/pkg/util/podutil_test.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/util/podutil.go
)) var annotationRemovePatch = []byte(fmt.Sprintf( `{"metadata":{"annotations":{"%s":null}}}`, constants.AmbientRedirection, )) // PodRedirectionEnabled determines if a pod should or should not be configured // to have traffic redirected thru the node proxy. func PodRedirectionEnabled(namespace *corev1.Namespace, pod *corev1.Pod) bool { if !(namespace.GetLabels()[constants.DataplaneModeLabel] == constants.DataplaneModeAmbient ||
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
ns := s.namespaces.Get(podNamespace, "") if ns == nil { return nil, fmt.Errorf("failed to find namespace %v", ns) } 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 - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
if err != nil { return false, err } ns, err := client.CoreV1().Namespaces().Get(context.Background(), podNamespace, metav1.GetOptions{}) if err != nil { return false, err } return util.PodRedirectionEnabled(ns, pod), nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0)