- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for wasn (0.14 sec)
-
cni/pkg/log/uds_test.go
loggingOptions.WithTeeToUDS(udsSock, constants.UDSLogPath) assert.NoError(t, log.Configure(loggingOptions)) log.FindScope("default").SetOutputLevel(log.DebugLevel) log.Debug("debug log") log.Info("info log") log.Warn("warn log") log.Error("error log") // This will error because stdout cannot sync, but the UDS part should sync // Ideally we would fail if the UDS part fails but the error library makes it kind of tricky _ = log.Sync()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
if openNetns != nil { return openNetns, nil } log.Debug("pod netns was not found, trying to find it using procfs") // 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. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err }
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/nodeagent/ztunnelserver.go
log.Debugf("ztunnel keepalive failed: %v", err) if errors.Is(err, io.EOF) { log.Debug("ztunnel EOF") return nil } return err case err == nil: log.Warn("ztunnel protocol error, unexpected message") return fmt.Errorf("ztunnel protocol error, unexpected message") default: // we get here if error is deadline exceeded, which means ztunnel is alive. }
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/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" { t.Logf("PASS: File %v was removed from %v", f, tempCNIBinDir) return nil
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/pluginlistener/listener.go
} // Attempt to create the folder in case it doesn't exist if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil { // If we cannot create it, just warn here - we will fail later if there is a real error log.Warnf("Failed to create directory for %v: %v", path, err) } var err error listener, err := net.Listen("unix", path) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // wait until pod add was called mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(1)) log.Debug("labeling namespace") _, err := client.Kube().CoreV1().Namespaces().Patch(ctx, ns.Name,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
assert.NoError(t, err) assert.Equal(t, ztunnelServer.deletedPods.Load(), 1) assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1) assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
installerScope.Debugf("Using the following manifest to install operator:\n%s\n", mstr) opts := &applyOptions{ DryRun: args.DryRun, } // If CR was passed, we must create a namespace for it and install CR into it. customResource, istioNamespace, err := getCRAndNamespaceFromFile(oiArgs.inFilename, l) if err != nil { l.LogAndFatal(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
operator/cmd/mesh/install.go
err = detectDefaultWebhookChange(p, kubeClient, iop, exists) if err != nil { return fmt.Errorf("failed to detect the default webhook change: %v", err) } // Warn users if they use `istioctl install` without any config args. if !rootArgs.DryRun && !iArgs.SkipConfirmation { prompt := fmt.Sprintf("This will install the Istio %s %q profile (with components: %s) into the cluster. Proceed? (y/N)",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
cni/pkg/nodeagent/informers.go
pod := event.Latest().(*corev1.Pod) defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment() switch event.Event { case controllers.EventAdd: // pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to!
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)