- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for podname (0.12 sec)
-
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) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K 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),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 01:29:35 UTC 2024 - 20.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
func getPodNameWithNamespace(ctx cli.Context, podflag, ns string) (string, string, error) { var podName, podNamespace string podName, podNamespace, err := ctx.InferPodInfoFromTypedResource(podflag, ns) if err != nil { return "", "", err } return podName, podNamespace, nil } func setupZtunnelConfigDumpWriter(kubeClient kube.CLIClient, podName, podNamespace string, out io.Writer) (*ztunnelDump.ConfigWriter, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pkg/kube/client.go
return nil, nil } func (c *client) EnvoyDo(ctx context.Context, podName, podNamespace, method, path string) ([]byte, error) { return c.portForwardRequest(ctx, podName, podNamespace, method, path, 15000) } func (c *client) EnvoyDoWithPort(ctx context.Context, podName, podNamespace, method, path string, port int) ([]byte, error) { return c.portForwardRequest(ctx, podName, podNamespace, method, path, port) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
return err } // Check if the workload is running under Kubernetes. podNamespace := string(k8sArgs.K8S_POD_NAMESPACE) podName := string(k8sArgs.K8S_POD_NAME) log := log.WithLabels("pod", podNamespace+"/"+podName) if podNamespace == "" || podName == "" { log.Debugf("Not a kubernetes pod") return nil } for _, excludeNs := range conf.Kubernetes.ExcludeNamespaces {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
// only use the first pod in the list podName = pl.Items[0].Name ns = pl.Items[0].Namespace } else if len(args) == 1 { podName, ns = args[0], ctx.IstioNamespace() } portForwarder, err := client.NewPortForwarder(podName, ns, "", 0, controlzPort) if err != nil { return fmt.Errorf("could not build port forwarder for ControlZ %s: %v", podName, err) } defer portForwarder.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 13.5K bytes - Viewed (0) -
tests/integration/pilot/tunneling_test.go
} func waitForTunnelingRemovedOrFail(ctx framework.TestContext, ns, app string) { istioCtl := istioctl.NewOrFail(ctx, ctx, istioctl.Config{Cluster: ctx.Clusters().Default()}) podName := getPodName(ctx, ns, app) args := []string{"proxy-config", "listeners", "-n", ns, podName, "-o", "json"} retry.UntilSuccessOrFail(ctx, func() error { out, _, err := istioCtl.Invoke(args) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// * the pod, if it is found and ambient is enabled func (s *InformerHandlers) GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) { ns := s.namespaces.Get(podNamespace, "") if ns == nil { return nil, fmt.Errorf("failed to find namespace %v", ns) } pod := s.pods.Get(podName, podNamespace) if pod == nil { return nil, fmt.Errorf("failed to find pod %v", ns) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K 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), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
if spec.DNSPolicy != "" && spec.DNSPolicy != corev1.DNSClusterFirst { podName := potentialPodName(metadata) log.Warnf("%q's DNSPolicy is not %q. The Envoy sidecar may not able to connect to Istio Pilot", metadata.Namespace+"/"+podName, corev1.DNSClusterFirst) } } func getInjectionStatus(podSpec corev1.PodSpec, revision string) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0)