- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 49 for Franke (0.15 sec)
-
istioctl/pkg/analyze/analyze.go
for _, s := range suppress { parts := strings.Split(s, "=") if len(parts) != 2 { return fmt.Errorf("%s is not a valid suppression value. See istioctl analyze --help", s) } // Check to see if the supplied code is valid. If not, emit a // warning but continue. codeIsValid := false for _, at := range msg.All() { if at.Code() == parts[0] {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
cni/pkg/util/podutil.go
// K8S may not have received the pod IPs yet, and may not report the pod as having any. func GetPodIPsIfPresent(pod *corev1.Pod) []netip.Addr { var podIPs []netip.Addr if len(pod.Status.PodIPs) != 0 { for _, pip := range pod.Status.PodIPs { ip := netip.MustParseAddr(pip.IP) podIPs = append(podIPs, ip) } } else if len(pod.Status.PodIP) != 0 { ip := netip.MustParseAddr(pod.Status.PodIP) podIPs = append(podIPs, ip) }
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) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
execClientConfig: loggingConfig, args: strings.Split("log ztunnel-9v7nw --level debug", " "), expectedString: "current log level is debug", wantException: false, }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) { verifyExecTestOutput(t, ZtunnelConfig(cli.NewFakeContext(&cli.NewFakeContextOption{ Results: c.execClientConfig,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
} } func TestPodsAppearsWithNilNetnsWhenEnsureIsUsed(t *testing.T) { p := newPodNetnsCache(openNsTestOverride) p.Ensure("123") found := false snap := p.ReadCurrentPodSnapshot() for k, v := range snap { if k == "123" && v == (WorkloadInfo{}) { found = true } } if !found { t.Fatalf("expected pod 123 to be in the cache") } } func TestUpsertPodCacheWithLiveNetns(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
if err != nil { return fmt.Errorf("failure running port forward process: %v", err) } printHeader(c.OutOrStdout()) workloads := args for _, workload := range workloads { sm, err := metrics(promAPI, workload, metricsDuration) if err != nil { return fmt.Errorf("could not build metrics for workload '%s': %v", workload, err) } printMetrics(c.OutOrStdout(), sm)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
args: strings.Split("route httpbin-794b576b6c-qx6pf", " "), expectedString: `config dump has no configuration type`, wantException: true, }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) { verifyExecTestOutput(t, ProxyConfig(cli.NewFakeContext(&cli.NewFakeContextOption{ Results: c.execClientConfig,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
log := log.WithLabels("pod", podNamespace+"/"+podName) if podNamespace == "" || podName == "" { log.Debugf("Not a kubernetes pod") return nil } for _, excludeNs := range conf.Kubernetes.ExcludeNamespaces { if podNamespace == excludeNs { log.Infof("pod namespace excluded") return nil } } // Begin ambient plugin logic
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) -
istioctl/pkg/precheck/precheck.go
if err != nil { return err } for _, se := range ses.Items { if se.Spec.Resolution != networking.ServiceEntry_NONE { continue } changed := false for _, p := range se.Spec.Ports { if p.TargetPort != 0 && p.Number != p.TargetPort { changed = true } } if changed {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
istioctl/cmd/root.go
Short: "Legacy command variants", } rootCmd.AddCommand(legacyCmd) for _, c := range xdsBasedTroubleshooting { rootCmd.AddCommand(c) } debugCmdAttachmentPoint = legacyCmd } else { debugCmdAttachmentPoint = rootCmd } for _, c := range xdsBasedTroubleshooting { experimentalCmd.AddCommand(c) } for _, c := range troubleshootingCommands { debugCmdAttachmentPoint.AddCommand(c) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
// this is similar to the way the injector sets all values proxyConfig.proxyMetadata to the Pod's env clusterEnv := map[string]string{} for _, metaMap := range []map[string]string{config.ProxyMetadata, overrides} { for k, v := range metaMap { clusterEnv[k] = v } } return os.WriteFile(filepath.Join(dir, "cluster.env"), []byte(mapToString(clusterEnv)), filePerms) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0)