- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for podname (0.18 sec)
-
istioctl/pkg/util/handlers/handlers.go
resname, ns := inferNsInfo(name, defaultNS) if !strings.Contains(resname, "/") { return []string{resname}, ns, nil } client, podName, namespace, selector, err := getClientForResource(resname, ns, factory) if err != nil { return []string{}, "", err } if podName != "" { return []string{podName}, namespace, err } options := metav1.ListOptions{LabelSelector: selector}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
multiXdsOpts.MessageWriter = c.OutOrStdout() if len(args) > 0 { podName, ns, err := ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace()) if err != nil { return err } if ambient.IsZtunnelPod(kubeClient, podName, ns) { _, _ = fmt.Fprintf(c.OutOrStdout(), "Sync diff is not available for ztunnel pod %s.%s\n", podName, ns) return nil } var envoyDump []byte
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName) defer log.Infof("============= End iptables configuration for %v =============", podName) return cmd.ProgramIptables(cfg) })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
// only use the first pod in the list podName = pl.Items[0].Name ns = pl.Items[0].Namespace } else { podName, ns, err = ctx.InferPodInfoFromTypedResource(args[0], ctx.IstioNamespace()) if err != nil { return err } } port := inferMonitoringPort(client, podName, ns) return portForward(podName, ns, fmt.Sprintf("Istio debug %s", podName),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
"istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" ) func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool { isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel } if v, ok := pod.Labels["app"]; ok {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
if err != nil { return err } var podName, podNs string var podLabels, nsLabels map[string]string if len(args) == 1 { podName, podNs, err = ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace()) if err != nil { return err } pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
var errs *multierror.Error for _, podName := range podNames { if len(destLoggerLevels) == 0 { resp, err = setupEnvoyLogConfig(kubeClient, "", podName, podNamespace) } else { if ll, ok := destLoggerLevels[defaultLoggerName]; ok { // update levels of all loggers first resp, err = setupEnvoyLogConfig(kubeClient, defaultLoggerName+"="+levelToString[ll], podName, podNamespace) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_intercept_rule_mgr.go
// limitations under the License. package plugin // InterceptRuleMgr configures networking tables (e.g. iptables or nftables) for // redirecting traffic to an Istio proxy. type InterceptRuleMgr interface { Program(podName, netns string, redirect *Redirect) error } // Constructor for iptables InterceptRuleMgr func IptablesInterceptRuleMgr() InterceptRuleMgr { return newIPTables()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 940 bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
gotPodName, gotNamespace := InferPodInfo(tt.proxyName, tt.namespace) if gotPodName != tt.wantPodName || gotNamespace != tt.wantNamespace { t.Errorf("unexpected podName and namespace: wanted %v %v got %v %v", tt.wantPodName, tt.wantNamespace, gotPodName, gotNamespace) } }) } } func TestInferPodInfoFromTypedResource(t *testing.T) { tests := []struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
brokenPodTerminating = makePod(makePodArgs{ PodName: "broken-pod-terminating", Annotations: map[string]string{ "sidecar.istio.io/status": "something", }, Labels: map[string]string{ "testlabel": "true", }, NodeName: "test-node", InitContainerStatus: &brokenInitContainerTerminating, }) brokenPodWaiting = makePod(makePodArgs{ PodName: "broken-pod-waiting",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 12 17:39:53 GMT 2023 - 4.7K bytes - Viewed (0)