- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 568 for pod9 (2.23 sec)
-
pkg/kubelet/apis/podresources/server_v1alpha1_test.go
desc string pods []*v1.Pod devices []*podresourcesv1.ContainerDevices expectedResponse *v1alpha1.ListPodResourcesResponse }{ { desc: "no pods", pods: []*v1.Pod{}, devices: []*podresourcesv1.ContainerDevices{}, expectedResponse: &v1alpha1.ListPodResourcesResponse{}, }, { desc: "pod without devices", pods: []*v1.Pod{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
sortBy := func(pods []*corev1.Pod) sort.Interface { return podutils.ByLogging(pods) } timeout := 2 * time.Second if getFirstPodFunc == nil { getFirstPodFunc = polymorphichelpers.GetFirstPod } pod, _, err := getFirstPodFunc(client, namespace, selector, timeout, sortBy) if err != nil { return "", "", fmt.Errorf("no pods match %q", resname) } return pod.Name, namespace, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 06 15:01:41 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/scheduler/metrics/resources/resources.go
// scenarios for efficiency. func podRequestsAndLimitsByLifecycle(pod *v1.Pod, reuseReqs, reuseLimits v1.ResourceList) (reqs, limits v1.ResourceList, terminal bool) { switch { case len(pod.Spec.NodeName) == 0: // unscheduled pods cannot be terminal case pod.Status.Phase == v1.PodSucceeded, pod.Status.Phase == v1.PodFailed: terminal = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 23:15:53 UTC 2023 - 6.8K bytes - Viewed (0) -
pkg/kubelet/eviction/types.go
type MirrorPodFunc func(*v1.Pod) (*v1.Pod, bool) // ActivePodsFunc returns pods bound to the kubelet that are active (i.e. non-terminal state) type ActivePodsFunc func() []*v1.Pod // PodCleanedUpFunc returns true if all resources associated with a pod have been reclaimed. type PodCleanedUpFunc func(*v1.Pod) bool // statsFunc returns the usage stats if known for an input pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
} func (s *secretManager) RegisterPod(pod *v1.Pod) { s.manager.RegisterPod(pod) } func (s *secretManager) UnregisterPod(pod *v1.Pod) { s.manager.UnregisterPod(pod) } func getSecretNames(pod *v1.Pod) sets.Set[string] { result := sets.New[string]() podutil.VisitPodSecretNames(pod, func(name string) bool { result.Insert(name) return true }) return result
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
versioner := storage.APIObjectVersioner{} makePod := func(name string) *example.Pod { return &example.Pod{ ObjectMeta: metav1.ObjectMeta{Namespace: "ns", Name: name}, } } createPod := func(obj *example.Pod) *example.Pod { key := "pods/" + obj.Namespace + "/" + obj.Name out := &example.Pod{} err := etcdStorage.Create(context.TODO(), key, obj, out, 0) require.NoError(t, err) return out }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
args: strings.Split("clusters invalid", " "), expectedString: "unable to retrieve Pod: pods \"invalid\" not found", wantException: true, // "istioctl proxy-config clusters invalid" should fail }, { // listeners invalid args: strings.Split("listeners invalid", " "), expectedString: "unable to retrieve Pod: pods \"invalid\" not found", wantException: true, // "istioctl proxy-config listeners invalid" should fail
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 21:51:29 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
send := func(objs []interface{}) { var pods []*v1.Pod for _, o := range objs { pods = append(pods, o.(*v1.Pod)) } updates <- kubetypes.PodUpdate{Pods: pods, Op: kubetypes.SET, Source: kubetypes.ApiserverSource} } r := cache.NewReflector(lw, &v1.Pod{}, cache.NewUndeltaStore(send, cache.MetaNamespaceKeyFunc), 0) go r.Run(wait.NeverStop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
plugin/pkg/admission/namespace/autoprovision/admission_test.go
t.Errorf("unexpected error initializing handler: %v", err) } informerFactory.Start(wait.NeverStop) pod := newPod(namespace) err = admissiontesting.WithReinvocationTesting(t, handler).Admit(context.TODO(), admission.NewAttributesRecord(&pod, nil, api.Kind("Pod").WithVersion("version"), pod.Namespace, pod.Name, api.Resource("pods").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil), nil) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 7.5K bytes - Viewed (0) -
releasenotes/notes/injector-selectors.yaml
if they exist in a namespace without an `istio-injection` label set but have the `sidecar.istio.io/inject` label set on the pod. This is expected to be an uncommon case, so for most users there will be no behavioral changes to existing pods. If this behavior is not desired, it can be temporarily disabled with `--set values.sidecarInjectorWebhook.useLegacySelectors=true`.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 01 15:34:22 UTC 2021 - 1.6K bytes - Viewed (0)