Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for newTimer (0.21 sec)

  1. pkg/kubelet/status/status_manager_test.go

    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			UID:       "12345678",
    			Name:      "foo",
    			Namespace: "new",
    		},
    		Status: v1.PodStatus{},
    	}
    	now := metav1.Now()
    	startTime := metav1.NewTime(now.Time.Add(-1 * time.Minute))
    	pod.Status.StartTime = &startTime
    	syncer.SetPodStatus(pod, getRandomPodStatus())
    
    	status := expectPodStatus(t, syncer, pod)
    	if !status.StartTime.Time.Equal(startTime.Time) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_utils_test.go

    func TestOverlappingStatefulSets(t *testing.T) {
    	sets := make([]*apps.StatefulSet, 10)
    	perm := rand.Perm(10)
    	for i, v := range perm {
    		sets[i] = newStatefulSet(10)
    		sets[i].CreationTimestamp = metav1.NewTime(sets[i].CreationTimestamp.Add(time.Duration(v) * time.Second))
    	}
    	sort.Sort(overlappingStatefulSets(sets))
    	if !sort.IsSorted(overlappingStatefulSets(sets)) {
    		t.Error("ascendingOrdinal fails to sort Pods")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_mounter_test.go

    					tr.Spec.Audiences = []string{"api"}
    				}
    				tr.Status.Token = fmt.Sprintf("%v:%v:%d:%v", action.GetNamespace(), testAccount, *tr.Spec.ExpirationSeconds, tr.Spec.Audiences)
    				tr.Status.ExpirationTimestamp = meta.NewTime(time.Unix(1, 1))
    				return true, tr, nil
    			}))
    			plug, tmpDir := newTestPlugin(t, client)
    			defer os.RemoveAll(tmpDir)
    			mounter, err := plug.NewMounter(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 50.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top