- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 193 for pdName (0.1 sec)
-
pkg/kubelet/apis/podresources/server_v1_test.go
Memory: mockMemoryProvider, DynamicResources: mockDynamicResourcesProvider, } server := NewV1PodResourcesServer(providers) podReq := &podresourcesapi.GetPodResourcesRequest{PodName: podName, PodNamespace: podNamespace} resp, err := server.Get(context.TODO(), podReq) if err != nil { if err.Error() != tc.err.Error() { t.Errorf("want exit = %v, got %v", tc.err, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
) func extractConfigDump(kubeClient kube.CLIClient, podName, podNamespace string, eds bool) ([]byte, error) { path := "config_dump" if eds { path += "?include_eds=true" } debug, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "GET", path, proxyAdminPort) if err != nil { return nil, fmt.Errorf("failed to execute command on %s.%s sidecar: %v", podName, podNamespace, err) } return debug, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
// volumes are mounted. func (vm *volumeManager) verifyVolumesMountedFunc(podName types.UniquePodName, expectedVolumes []string) wait.ConditionWithContextFunc { return func(_ context.Context) (done bool, err error) { if errs := vm.desiredStateOfWorld.PopPodErrors(podName); len(errs) > 0 { return true, errors.New(strings.Join(errs, "; ")) } return len(vm.getUnmountedVolumes(podName, expectedVolumes)) == 0, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K 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
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
defer server.Terminate(t) defer storage.Store.DestroyFunc() client := fake.NewSimpleClientset(tc.pdb) for _, podName := range []string{"foo-1", "foo-2"} { pod := validNewPod() pod.Labels = map[string]string{"a": "true"} pod.ObjectMeta.Name = podName pod.Spec.NodeName = "foo" newPod, err := storage.Create(testContext, pod, nil, &metav1.CreateOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K 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) -
pkg/controller/podautoscaler/replica_calculator.go
fallbackUtilization := int64(max(100, targetUtilization)) for podName := range missingPods { metrics[podName] = metricsclient.PodMetric{Value: requests[podName] * fallbackUtilization / 100} } } else if usageRatio > 1.0 { // on a scale-up, treat missing pods as using 0% of the resource request for podName := range missingPods { metrics[podName] = metricsclient.PodMetric{Value: 0} } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
allocs = make([]float64, len(items)) for idx, plName := range plNames { plState := plStates[plName] allocs[idx] = float64(plState.currentCL) } } for idx, plName := range plNames { plState := plStates[plName] if setCompleters { qsCompleter, err := queueSetCompleterForPL(cfgCtlr.queueSetFactory, plState.queues,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
security/pkg/server/ca/node_auth_test.go
{Name: "ztunnel", Namespace: "istio-system"}: {}, } ztunnelCaller := security.KubernetesInfo{ PodName: "ztunnel-a", PodNamespace: "istio-system", PodUID: "12345", PodServiceAccount: "ztunnel", } ztunnelPod := pod{ name: ztunnelCaller.PodName, namespace: ztunnelCaller.PodNamespace, account: ztunnelCaller.PodServiceAccount, uid: ztunnelCaller.PodUID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world.go
} dsw.nodesManaged[nodeName].volumesToAttach[volumeName] = volumeObj } if _, podExists := volumeObj.scheduledPods[podName]; !podExists { dsw.nodesManaged[nodeName].volumesToAttach[volumeName].scheduledPods[podName] = pod{ podName: podName, podObj: podToAdd, } } return volumeName, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 13.5K bytes - Viewed (0)