- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 560 for podIps (0.98 sec)
-
pkg/controller/tainteviction/taint_eviction.go
// getPodsAssignedToNode can be delayed as long as all future updates to pods will call // tc.PodUpdated which will use tc.taintedNodes to potentially delete delayed pods. pods, err := tc.getPodsAssignedToNode(node.Name) if err != nil { logger.Error(err, "Failed to get pods assigned to node", "node", klog.KObj(node)) return } if len(pods) == 0 { return } // Short circuit, to make this controller a bit faster.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/authz.go
GetResource() schema.GroupVersionResource // GetSubresource is the name of the subresource being requested. This is a different resource, scoped to the parent resource, but it may have a different kind. // For instance, /pods has the resource "pods" and the kind "Pod", while /pods/foo/status has the resource "pods", the sub resource "status", and the kind "Pod"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 21:31:27 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/controller/deployment/rolling.go
// // maxScaledDown := allPodsCount - minAvailable - newReplicaSetPodsUnavailable // take into account not only maxUnavailable and any surge pods that have been created, but also unavailable pods from // the newRS, so that the unavailable pods from the newRS would not make us scale down old replica sets in a further // step(that will increase unavailability). // // Concrete example: // // * 10 replicas
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 07:09:11 UTC 2023 - 9.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd_test.go
tests := []struct { name string pods []testresources.FakeStaticPod clientSetup func(*clientsetfake.Clientset) expectedEndpoints []string expectedErr bool }{ { name: "no pods", expectedEndpoints: []string{}, }, { name: "exactly one pod with annotation", pods: []testresources.FakeStaticPod{ { NodeName: "cp-0",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 20.3K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
}) } } func fakeClient(pods ...*corev1.Pod) kube.Client { var csPods []runtime.Object for _, pod := range pods { csPods = append(csPods, pod.DeepCopy()) } return kube.NewFakeClient(csPods...) } func makePodLabelMap(pods []*corev1.Pod) (podmap map[string]string) { podmap = map[string]string{} for _, pod := range pods { podmap[pod.Name] = ""
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
logger := klog.FromContext(ctx) pods, err := dc.getPodsForPdb(pdb) if err != nil { dc.recorder.Eventf(pdb, v1.EventTypeWarning, "NoPods", "Failed to get pods: %v", err) return err } if len(pods) == 0 { dc.recorder.Eventf(pdb, v1.EventTypeNormal, "NoPods", "No matching pods found") } expectedCount, desiredHealthy, unmanagedPods, err := dc.getExpectedPodCount(ctx, pdb, pods) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
} // Options for the status server. type Options struct { // Ip of the pod. Note: this is only applicable for Kubernetes pods and should only be used for // the prober. PodIP string // KubeAppProbers is a json with Kubernetes application prober config encoded. KubeAppProbers string NodeType model.NodeType StatusPort uint16
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio_test.go
name: "resources requested, pods scheduled with more resources", pods: []*v1.Pod{ st.MakePod().Obj(), }, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { state := framework.NewCycleState() snapshot := cache.NewSnapshot(test.pods, test.nodes) _, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 21.2K bytes - Viewed (0) -
pkg/scheduler/util/utils_test.go
var priority int32 = 1 currentTime := time.Now() tests := []struct { name string pods []*v1.Pod expectedStartTime *metav1.Time }{ { name: "Pods length is 0", pods: []*v1.Pod{}, expectedStartTime: nil, }, { name: "generate new startTime", pods: []*v1.Pod{ newPriorityPodWithStartTime("pod1", 1, currentTime.Add(-time.Second)), {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 14.5K bytes - Viewed (0)