- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 568 for podIps (0.11 sec)
-
pkg/quota/v1/evaluator/core/pods_test.go
}{ { name: "nil case", }, { name: "all pods in running state", objs: []runtime.Object{ makePod("p1", "", cpu1, api.PodRunning), makePod("p2", "", cpu1, api.PodRunning), }, want: corev1.ResourceList{ corev1.ResourcePods: resource.MustParse("2"), corev1.ResourceName("count/pods"): resource.MustParse("2"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
if err != nil { t.Fatal(err) } pods := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "pods"} secrets := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "secrets"} deployments := schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: "deployments"} listersForResourceConfig := map[schema.GroupVersionResource]cache.GenericLister{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0) -
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/auth/authorizer/abac/abac_test.go
ExpectDecision authorizer.Decision }{ // Scheduler can read pods {User: uScheduler, Verb: "list", Resource: "pods", NS: "ns1", ExpectDecision: authorizer.DecisionAllow}, {User: uScheduler, Verb: "list", Resource: "pods", NS: "", ExpectDecision: authorizer.DecisionAllow}, // Scheduler cannot write pods {User: uScheduler, Verb: "create", Resource: "pods", NS: "ns1", ExpectDecision: authorizer.DecisionNoOpinion},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 24 15:14:54 UTC 2019 - 40K 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)