- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 59 for pdName (0.1 sec)
-
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) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 2.1K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
for _, workload := range workloads { podName := workload[0].WorkloadsOrFail(t)[0].PodName() namespace := workload.Config().Namespace.Name() retry.UntilSuccessOrFail(t, func() error { args := []string{ "x", "proxy-status", "--xds-via-agents", fmt.Sprintf("%s.%s", podName, namespace), } output, _, err := istioCtl.Invoke(args) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1_test.go
"k8s.io/kubelet/pkg/apis/podresources/v1alpha1" podresourcetest "k8s.io/kubernetes/pkg/kubelet/apis/podresources/testing" ) func TestListPodResourcesV1alpha1(t *testing.T) { podName := "pod-name" podNamespace := "pod-namespace" podUID := types.UID("pod-uid") containerName := "container-name" devs := []*podresourcesv1.ContainerDevices{ { ResourceName: "resource",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime)) }() pv, err := c.pvLister.Get(pvName) if apierrors.IsNotFound(err) { logger.V(4).Info("PV not found, ignoring", "PV", klog.KRef("", pvName)) return nil } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/stats/host_stats_provider.go
} func (h hostStatsProvider) podLogMetrics(podNamespace, podName string, podUID types.UID) (metricsProviderByPath, error) { podLogsDirectoryPath := kuberuntime.BuildPodLogsDirectory(h.podLogsDirectory, podNamespace, podName, podUID) return h.fileMetricsByDir(podLogsDirectoryPath) } func (h hostStatsProvider) podContainerLogMetrics(podNamespace, podName string, podUID types.UID, containerName string) (metricsProviderByPath, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 6.6K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
} } else if len(args) == 1 { podName, podNamespace, err := ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace()) if err != nil { return err } configDump, err = getConfigDumpFromPod(kubeClient, podName, podNamespace) if err != nil { return fmt.Errorf("failed to get config dump from pod %s in %s", podName, podNamespace) } } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 5K bytes - Viewed (0) -
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}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 06 15:01:41 UTC 2024 - 6.2K 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
} } func (c *PVAssumeCache) GetPV(pvName string) (*v1.PersistentVolume, error) { obj, err := c.Get(pvName) if err != nil { return nil, err } pv, ok := obj.(*v1.PersistentVolume) if !ok { return nil, &assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj} } return pv, nil } func (c *PVAssumeCache) GetAPIPV(pvName string) (*v1.PersistentVolume, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 3.7K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
} // Currently we only use the netns from the original CNI event addEvent := nodeagent.CNIPluginAddEvent{Netns: event.Netns, PodName: podName, PodNamespace: podNamespace, IPs: ncconfigs} eventData, err := json.Marshal(addEvent) if err != nil { return err } var response *http.Response
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 2.4K bytes - Viewed (0)