Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 120 for newTimer (0.23 sec)

  1. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    // in prior operation, but the pod remains with deletion timestamp
    // and grace period set to 0.
    func TestGracefulStoreCanDeleteIfExistingGracePeriodZero(t *testing.T) {
    	deletionTimestamp := metav1.NewTime(time.Now())
    	deletionGracePeriodSeconds := int64(0)
    	initialGeneration := int64(1)
    	pod := &example.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:                       "foo",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  2. pkg/controller/disruption/disruption_test.go

    		updatedPDB.Status.DisruptionsAllowed -= int32(len(podNames))
    		updatedPDB.Status.DisruptedPods = make(map[string]metav1.Time)
    		for _, name := range podNames {
    			updatedPDB.Status.DisruptedPods[name] = metav1.NewTime(dc.clock.Now())
    		}
    		if err := dc.coreClient.Tracker().Update(poddisruptionbudgetsResource, updatedPDB, updatedPDB.Namespace); err != nil {
    			t.Fatalf("Eviction (PDB update) failed: %v", err)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    const fastRequeue = 10 * time.Millisecond
    
    // testFinishedAt represents time one second later than unix epoch
    // this will be used in various test cases where we don't want back-off to kick in
    var testFinishedAt = metav1.NewTime((time.Time{}).Add(time.Second))
    
    func newJobWithName(name string, parallelism, completions, backoffLimit int32, completionMode batch.CompletionMode) *batch.Job {
    	j := &batch.Job{
    		TypeMeta: metav1.TypeMeta{Kind: "Job"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    		flowSchema: fs,
    		condition: flowcontrol.FlowSchemaCondition{
    			Type:               flowcontrol.FlowSchemaConditionDangling,
    			Status:             desiredStatus,
    			LastTransitionTime: metav1.NewTime(now),
    			Reason:             desiredReason,
    			Message:            desiredMessage,
    		},
    		oldValue: *danglingCondition})
    }
    
    // imaginePL adds a priority level based on one of the mandatory ones
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  5. pkg/printers/internalversion/printers.go

    	restarts := 0
    	restartableInitContainerRestarts := 0
    	totalContainers := len(pod.Spec.Containers)
    	readyContainers := 0
    	lastRestartDate := metav1.NewTime(time.Time{})
    	lastRestartableInitContainerRestartDate := metav1.NewTime(time.Time{})
    
    	podPhase := pod.Status.Phase
    	reason := string(podPhase)
    	if pod.Status.Reason != "" {
    		reason = pod.Status.Reason
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  6. pkg/controller/podautoscaler/horizontal.go

    		DesiredReplicas: desiredReplicas,
    		LastScaleTime:   hpa.Status.LastScaleTime,
    		CurrentMetrics:  metricStatuses,
    		Conditions:      hpa.Status.Conditions,
    	}
    
    	if rescale {
    		now := metav1.NewTime(time.Now())
    		hpa.Status.LastScaleTime = &now
    	}
    }
    
    // updateStatusIfNeeded calls updateStatus only if the status of the new HPA is not the same as the old status
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  7. pkg/controller/endpointslice/endpointslice_controller_test.go

    	t.Helper()
    	service := &v1.Service{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:              serviceName,
    			Namespace:         namespace,
    			CreationTimestamp: metav1.NewTime(time.Now()),
    			UID:               types.UID(namespace + "-" + serviceName),
    		},
    		Spec: v1.ServiceSpec{
    			Ports:      []v1.ServicePort{{TargetPort: intstr.FromInt32(80)}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  8. pkg/controller/statefulset/stateful_set_control_test.go

    	pod := newStatefulSetPod(set, ordinal)
    	pod.SetUID(types.UID(pod.Name + "-uid")) // To match fakeObjectManager.CreatePod
    	pod.Status.Phase = v1.PodRunning
    	deleted := metav1.NewTime(time.Now())
    	pod.DeletionTimestamp = &deleted
    	condition := v1.PodCondition{Type: v1.PodReady, Status: v1.ConditionTrue}
    	fakeResourceVersion(pod)
    	podutil.UpdatePodCondition(&pod.Status, &condition)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    		objectMeta.SetGeneration(objectMeta.GetGeneration() + 1)
    	}
    	existingDeletionTimestamp := objectMeta.GetDeletionTimestamp()
    	if existingDeletionTimestamp == nil || existingDeletionTimestamp.After(now) {
    		metaNow := metav1.NewTime(now)
    		objectMeta.SetDeletionTimestamp(&metaNow)
    	}
    	var zero int64 = 0
    	objectMeta.SetDeletionGracePeriodSeconds(&zero)
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  10. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    	healthyNodeNewStatus := v1.NodeStatus{
    		Conditions: []v1.NodeCondition{
    			{
    				Type:               v1.NodeReady,
    				Status:             v1.ConditionTrue,
    				LastHeartbeatTime:  metav1.NewTime(fakeNow.Add(timeToPass)),
    				LastTransitionTime: fakeNow,
    			},
    		},
    	}
    	unhealthyNodeNewStatus := v1.NodeStatus{
    		Conditions: []v1.NodeCondition{
    			{
    				Type:   v1.NodeReady,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
Back to top