Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 44 of 44 for NewInternalError (0.5 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    	}
    	waiter := newAdmissionWaiter(a)
    
    	e.addWork(waiter)
    
    	// wait for completion or timeout
    	select {
    	case <-waiter.finished:
    	case <-time.After(10 * time.Second):
    		return apierrors.NewInternalError(fmt.Errorf("resource quota evaluation timed out"))
    	}
    
    	return waiter.result
    }
    
    func (e *quotaEvaluator) addWork(a *admissionWaiter) {
    	e.workLock.Lock()
    	defer e.workLock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    		return out, false, err
    	}
    	// check if obj has pending finalizers
    	accessor, err := meta.Accessor(obj)
    	if err != nil {
    		return nil, false, apierrors.NewInternalError(err)
    	}
    	pendingFinalizers := len(accessor.GetFinalizers()) != 0
    	var ignoreNotFound bool
    	var deleteImmediately bool = true
    	var lastExisting, out runtime.Object
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  3. pkg/controller/cronjob/cronjob_controllerv2_test.go

    					},
    					Status: batchv1.JobStatus{StartTime: &metav1.Time{Time: justBeforeTheHour()}},
    				},
    			},
    			jobCreateError:      errors.NewInternalError(fmt.Errorf("quota for # of jobs reached")),
    			expectedDeletedJobs: []string{"finished-job-started-hour-ago"},
    		},
    		{
    			name: "jobs are not deleted if history limit not reached",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  4. pkg/controller/history/controller_history_test.go

    		default:
    			return false, nil, nil
    		}
    	}
    	internalError := func(action core.Action) (bool, runtime.Object, error) {
    		switch action.(type) {
    		case core.UpdateActionImpl:
    			return true, nil, errors.NewInternalError(fmt.Errorf("internal error"))
    		default:
    			return false, nil, nil
    		}
    	}
    
    	testFn := func(test *testcase, t *testing.T) {
    		client := fake.NewSimpleClientset()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 49.1K bytes
    - Viewed (0)
Back to top