- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for podsName (0.17 sec)
-
istioctl/pkg/completion/completion.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K 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/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/multixds/gather.go
} slice := strings.SplitN(dr.ResourceNames[0], ".", 2) if len(slice) != 2 { return nil, fmt.Errorf("invalid resource name format: %v", slice) } podName := slice[0] ns := slice[1] pod, err := kubeClient.Kube().CoreV1().Pods(ns).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return nil, err } resp, err := queryToOnePod(pod) if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K 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) -
cni/pkg/plugin/plugin_test.go
testServer.Close() return cniAddServerCalled } } func buildCmdArgs(stdinData, podName, podNamespace string) *skel.CmdArgs { return &skel.CmdArgs{ ContainerID: "testContainerID", Netns: testSandboxDirectory, IfName: "eth0", Args: fmt.Sprintf("K8S_POD_NAMESPACE=%s;K8S_POD_NAME=%s", podNamespace, podName), Path: "/tmp", StdinData: []byte(stdinData), } }
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) -
istioctl/pkg/cli/mock_client.go
return c.Results, nil } func (c MockClient) EnvoyDo(ctx context.Context, podName, podNamespace, method, path string) ([]byte, error) { results, ok := c.Results[podName] if !ok { return nil, fmt.Errorf("unable to retrieve Pod: pods %q not found", podName) } return results, nil } func (c MockClient) EnvoyDoWithPort(ctx context.Context, podName, podNamespace, method, path string, port int) ([]byte, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
var podNamespace string if len(args) == 1 { podName, ns, err := getComponentPodName(ctx, args[0]) if err != nil { return err } ztunnelPod := ambientutil.IsZtunnelPod(kubeClient, podName, ns) if !ztunnelPod { return fmt.Errorf("workloads command is only supported by Ztunnel proxies: %v", podName) } podNames = []string{podName} podNamespace = ns } else { var err error
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0)