Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 59 for badpod (0.16 sec)

  1. 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)
  2. plugin/pkg/auth/authorizer/node/graph.go

    	})
    	g.destinationEdgeIndex[n.ID()] = index
    }
    
    // AddPod should only be called once spec.NodeName is populated.
    // It sets up edges for the following relationships (which are immutable for a pod once bound to a node):
    //
    //	pod       -> node
    //	secret    -> pod
    //	configmap -> pod
    //	pvc       -> pod
    //	svcacct   -> pod
    func (g *Graph) AddPod(pod *corev1.Pod) {
    	start := time.Now()
    	defer func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  3. 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)
  4. src/main/resources/fess_message_fr.properties

    errors.failed_to_upload_elevate_file                 = Échec de l'envoi du fichier Elevate.
    errors.failed_to_download_badword_file               = Échec du téléchargement du fichier Badword.
    errors.failed_to_upload_badword_file                 = Échec de l'envoi du fichier Badword.
    errors.failed_to_download_mapping_file               = Échec du téléchargement du fichier Mapping.
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Mon Feb 06 22:59:17 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  5. 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)
  6. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    			return err
    		}
    		status := pl.fh.RunPreFilterExtensionRemovePod(ctx, state, pod, rpi, nodeInfo)
    		if !status.IsSuccess() {
    			return status.AsError()
    		}
    		return nil
    	}
    	addPod := func(api *framework.PodInfo) error {
    		nodeInfo.AddPodInfo(api)
    		status := pl.fh.RunPreFilterExtensionAddPod(ctx, state, pod, api, nodeInfo)
    		if !status.IsSuccess() {
    			return status.AsError()
    		}
    		return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    	if !needsCheck && s.conflictingPVCRefCount == 0 {
    		return nil, framework.NewStatus(framework.Skip)
    	}
    	cycleState.Write(preFilterStateKey, s)
    	return nil, nil
    }
    
    // AddPod from pre-computed data in cycleState.
    func (pl *VolumeRestrictions) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *InterPodAffinity) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    // AddPod from pre-computed data in cycleState.
    func (pl *InterPodAffinity) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
Back to top