Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 848 for relist (0.1 sec)

  1. pkg/controller/cronjob/cronjob_controllerv2.go

    			// We found an unfinished job that has us as the parent, but it is not in our Active list.
    			// This could happen if we crashed right after creating the Job and before updating the status,
    			// or if our jobs list is newer than our cj status after a relist, or if someone intentionally created
    			// a job that they wanted us to adopt.
    		} else if found && jobutil.IsJobFinished(j) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    	opts = append([]setupOption{withDefaults}, opts...)
    	for _, opt := range opts {
    		opt(&setupOpts)
    	}
    
    	server, etcdStorage := newEtcdTestStorage(t, etcd3testing.PathPrefix())
    	// Inject one list error to make sure we test the relist case.
    	wrappedStorage := &storagetesting.StorageInjectingListErrors{
    		Interface: etcdStorage,
    		Errors:    1,
    	}
    
    	config := Config{
    		Storage:        wrappedStorage,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set.go

    func (ssc *StatefulSetController) deletePod(logger klog.Logger, obj interface{}) {
    	pod, ok := obj.(*v1.Pod)
    
    	// When a delete is dropped, the relist will notice a pod in the store not
    	// in the list, leading to the insertion of a tombstone object which contains
    	// the deleted key/value. Note that this value might be stale.
    	if !ok {
    		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
    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. pkg/controller/job/job_controller.go

    	if condition := findConditionByType(list, cType); condition != nil {
    		if condition.Status != status || condition.Reason != reason || condition.Message != message {
    			*condition = *newCondition(cType, status, reason, message, now)
    			return list, true
    		}
    		return list, false
    	}
    	// A condition with that type doesn't exist in the list.
    	if status != v1.ConditionFalse {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  5. pkg/controller/daemon/daemon_controller.go

    	dsList, err := dsc.dsLister.List(labels.Everything())
    	if err != nil {
    		logger.V(4).Info("Error enqueueing daemon sets", "err", err)
    		return
    	}
    	node := obj.(*v1.Node)
    	for _, ds := range dsList {
    		if shouldRun, _ := NodeShouldRunDaemonPod(node, ds); shouldRun {
    			dsc.enqueueDaemonSet(ds)
    		}
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  6. pkg/controller/disruption/disruption.go

    	}
    }
    
    func (dc *DisruptionController) deletePod(logger klog.Logger, obj interface{}) {
    	pod, ok := obj.(*v1.Pod)
    	// When a delete is dropped, the relist will notice a pod in the store not
    	// in the list, leading to the insertion of a tombstone object which contains
    	// the deleted key/value. Note that this value might be stale. If the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  7. pkg/controller/replicaset/replica_set.go

    func (rsc *ReplicaSetController) deletePod(logger klog.Logger, obj interface{}) {
    	pod, ok := obj.(*v1.Pod)
    
    	// When a delete is dropped, the relist will notice a pod in the store not
    	// in the list, leading to the insertion of a tombstone object which contains
    	// the deleted key/value. Note that this value might be stale. If the pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. pkg/controller/replication/conversion.go

    }
    
    func convertSlice(rcList []*v1.ReplicationController) ([]*apps.ReplicaSet, error) {
    	rsList := make([]*apps.ReplicaSet, 0, len(rcList))
    	for _, rc := range rcList {
    		rs, err := convertRCtoRS(rc, nil)
    		if err != nil {
    			return nil, err
    		}
    		rsList = append(rsList, rs)
    	}
    	return rsList, nil
    }
    
    func convertList(rcList *v1.ReplicationControllerList) (*apps.ReplicaSetList, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 14 18:43:33 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/types2/call.go

    		x.mode = invalid
    	}
    
    	return statement
    }
    
    // exprList evaluates a list of expressions and returns the corresponding operands.
    // A single-element expression list may evaluate to multiple operands.
    func (check *Checker) exprList(elist []syntax.Expr) (xlist []*operand) {
    	if n := len(elist); n == 1 {
    		xlist, _ = check.multiExpr(elist[0], false)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 31.5K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_test.go

    		pod := attrs.Pod
    		newAllocatableResource := node.Allocatable.Clone()
    		for _, container := range pod.Spec.Containers {
    			for resource := range container.Resources.Requests {
    				newQuantity, exist := updateResourceMap[resource]
    				if !exist {
    					continue
    				}
    				if newQuantity.Value() < 0 {
    					return fmt.Errorf("Allocation failed")
    				}
    				newAllocatableResource.ScalarResources[resource] = newQuantity.Value()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top