- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Haddad (0.16 sec)
-
cni/pkg/nodeagent/net.go
} log.Debug("stopping ztunnel server") s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error { // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. filter := map[types.UID]*corev1.Pod{ pod.UID: pod, } return s.scanProcForPodsAndCache(filter) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
pod.Spec.Containers = []corev1.Container{app} testDoAddRun(t, cniConf, excludedNS, pod, ns) wasCalled := serverClose() // If the pod is being added to a namespace that is explicitly excluded by plugin config denylist // it should never be added, even if the namespace has the annotation assert.Equal(t, wasCalled, false) } func TestCmdAdd(t *testing.T) { pod, ns := buildFakePodAndNSForClient()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/test/install_cni.go
if op == "add" { t.Logf("PASS: File %v was added to %v", f, tempCNIBinDir) return nil } else if op == "del" { return fmt.Errorf("FAIL: File %v was not removed from %v", f, tempCNIBinDir) } } else { if op == "add" { return fmt.Errorf("FAIL: File %v was not added to %v", f, tempCNIBinDir) } else if op == "del" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
r := &zdsapi.WorkloadRequest{ Payload: &zdsapi.WorkloadRequest_Add{ Add: &zdsapi.AddWorkload{ WorkloadInfo: podToWorkload(pod), Uid: uid, }, }, } log.Infof("About to send added pod: %s to ztunnel: %+v", uid, r) data, err := proto.Marshal(r) if err != nil { return err } fd := int(netns.Fd()) resp, err := latestConn.send(ctx, data, &fd) if err != nil { return err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
m.With(resultLabel.Value(resultSuccess)).Increment() return nil } func (c *Controller) labelBrokenPod(pod *corev1.Pod) error { // Added for safety, to make sure no healthy pods get labeled. m := podsRepaired.With(typeLabel.Value(labelType)) repairLog.Infof("Pod detected as broken, adding label: %s/%s", pod.Namespace, pod.Name) labels := pod.GetLabels()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/cmd/root.go
registerStringParameter(constants.RepairLabelSelectors, "", "A set of label selectors in label=value format that will be added to the pod list filters") registerStringParameter(constants.RepairFieldSelectors, "", "A set of field selectors in label=value format that will be added to the pod list filters") } func registerStringParameter(name, value, usage string) { rootCmd.Flags().String(name, value, usage)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
// MutatingWebhookConfiguration and ValidatingWebhookConfiguration. The app of the webhooks are not general // since they are functioned differently with different name. // The filtered common labels are then added to the incoming generated // webhooks, which aids in managing these webhooks via the istioctl/operator. filteredLabels := make(map[string]string) for k, v := range wh.Labels { if k != "app" { filteredLabels[k] = v
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0)