- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 43 for badpod (0.13 sec)
-
platforms/jvm/plugins-java/src/integTest/groovy/org/gradle/java/compile/AbstractJavaCompilerIntegrationSpec.groovy
javaClassFile("compile/test/Person.class").exists() } def "compile bad code breaks the build and compilation error doesn't show link to help.gradle.org"() { given: badCode() when: fails("compileJava") then: output.contains(logStatement()) failure.assertHasErrorOutput("';' expected") failure.assertNotOutput("https://help.gradle.org")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 01 01:34:12 UTC 2024 - 27.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers_test.go
func randIP(s *string, r *rand.Rand) { *s = fmt.Sprintf("10.20.%d.%d", r.Int31n(256), r.Int31n(256)) } // randPod changes fields in pod to mimic another pod from the same replicaset. // The list fields here has been generated by picking two pods in the same replicaset // and checking diff of their jsons. func randPod(b *testing.B, pod *v1.Pod, r *rand.Rand) { pod.Name = fmt.Sprintf("%s-%x", pod.GenerateName, r.Int63n(1000))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
curPod := cur.(*v1.Pod) oldPod := old.(*v1.Pod) if curPod.ResourceVersion == oldPod.ResourceVersion { // In the event of a re-list we may receive update events for all known pods. // Two different versions of the same pod will always have different RVs. return } labelChanged := !reflect.DeepEqual(curPod.Labels, oldPod.Labels) curControllerRef := metav1.GetControllerOf(curPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
om.setsIndexer.Add(set1) om.setsIndexer.Add(set2) ssc.addPod(logger, pod1) key, done := ssc.queue.Get() if key == "" || done { t.Error("failed to enqueue StatefulSet") } else if expectedKey, _ := controller.KeyFunc(set1); expectedKey != key { t.Errorf("expected StatefulSet key %s found %s", expectedKey, key) } ssc.queue.Done(key) ssc.addPod(logger, pod2) key, done = ssc.queue.Get() if key == "" || done {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
for i := 1; i < 5; i++ { oldPod := newPod(fmt.Sprintf("node-%d-preserve-", i), fmt.Sprintf("node-%d", i), simpleDaemonSetLabel, ds) delete(oldPod.Labels, apps.ControllerRevisionHashLabelKey) oldPod.CreationTimestamp.Time = time.Unix(1, 0) oldPod.Status.Conditions = []v1.PodCondition{{Type: v1.PodReady, Status: v1.ConditionTrue}} manager.podStore.Add(oldPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
}) c.serviceLister = serviceInformer.Lister() c.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addPod, UpdateFunc: c.updatePod, DeleteFunc: c.deletePod, }) c.podLister = podInformer.Lister() c.podsSynced = podInformer.Informer().HasSynced c.nodeLister = nodeInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
n.PodsWithRequiredAntiAffinity = append(n.PodsWithRequiredAntiAffinity, podInfo) } n.update(podInfo.Pod, 1) } // AddPod is a wrapper around AddPodInfo. func (n *NodeInfo) AddPod(pod *v1.Pod) { // ignore this err since apiserver doesn't properly validate affinity terms // and we can't fix the validation for backwards compatibility. podInfo, _ := NewPodInfo(pod) n.AddPodInfo(podInfo)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
func TestLocality(t *testing.T) { namespace := "default" basePod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod", Namespace: namespace, Labels: map[string]string{}, }, Spec: v1.PodSpec{NodeName: "node"}, Status: v1.PodStatus{ PodIP: "1.2.3.4", Phase: v1.PodRunning, }, } setPodReady(basePod) baseNode := &v1.Node{ ObjectMeta: metav1.ObjectMeta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
dc.enqueuePdb(logger, pdb) } func (dc *DisruptionController) addPod(logger klog.Logger, obj interface{}) { pod := obj.(*v1.Pod) logger.V(4).Info("AddPod called on pod", "pod", klog.KObj(pod)) pdb := dc.getPdbForPod(logger, pod) if pdb == nil { logger.V(4).Info("No matching PDB for pod", "pod", klog.KObj(pod)) } else { logger.V(4).Info("addPod -> PDB", "pod", klog.KObj(pod), "podDisruptionBudget", klog.KObj(pdb))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// callbacks to make incremental updates to its supposedly pre-calculated // state. type PreFilterExtensions interface { // AddPod is called by the framework while trying to evaluate the impact // of adding podToAdd to the node while scheduling podToSchedule. AddPod(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, podInfoToAdd *PodInfo, nodeInfo *NodeInfo) *Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0)