- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 175 for newTimer (0.26 sec)
-
pkg/kubelet/stats/cri_stats_provider.go
StartTime: metav1.NewTime(time.Unix(0, container.CreatedAt)), CPU: &statsapi.CPUStats{}, Memory: &statsapi.MemoryStats{}, Rootfs: &statsapi.FsStats{}, Swap: &statsapi.SwapStats{}, // UserDefinedMetrics is not supported by CRI. } if stats.Cpu != nil { result.CPU.Time = metav1.NewTime(time.Unix(0, stats.Cpu.Timestamp))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 35.1K bytes - Viewed (0) -
src/net/http/server.go
// Double and clamp for next time. pollIntervalBase *= 2 if pollIntervalBase > shutdownPollIntervalMax { pollIntervalBase = shutdownPollIntervalMax } return interval } timer := time.NewTimer(nextPollInterval()) defer timer.Stop() for { if srv.closeIdleConns() { return lnerr } select { case <-ctx.Done(): return ctx.Err() case <-timer.C:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/database/sql/sql_test.go
_, err := db.Exec("will never run") errs <- err }() } opening.Wait() // wait for all workers to begin running const timeout = 5 * time.Second to := time.NewTimer(timeout) defer to.Stop() // check that all connections fail without deadlock for i := 0; i < tryOpen; i++ { select { case err := <-errs: if got, want := err, errOffline; got != want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/volume/util/resize_util_test.go
Status: v1.ConditionTrue, LastTransitionTime: currentTime, }, }).get() noConditionPVC := makePVC([]v1.PersistentVolumeClaimCondition{}).get() conditionFalseTime := metav1.Now() newTime := metav1.NewTime(time.Now().Add(1 * time.Hour)) testCases := []conditionMergeTestCase{ { description: "when removing all conditions", pvc: pvc.DeepCopy(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/validation/objectmeta_test.go
&metav1.ObjectMeta{Name: "test", ResourceVersion: "1", CreationTimestamp: metav1.NewTime(time.Unix(10, 0))}, field.NewPath("field"), ); len(errs) != 1 { t.Fatalf("unexpected errors: %v", errs) } if errs := ValidateObjectMetaUpdate( &metav1.ObjectMeta{Name: "test", ResourceVersion: "1", CreationTimestamp: metav1.NewTime(time.Unix(10, 0))}, &metav1.ObjectMeta{Name: "test", ResourceVersion: "1"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 07 03:12:31 UTC 2022 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/conditions.go
return false } existingCondition := FindStatusCondition(*conditions, newCondition.Type) if existingCondition == nil { if newCondition.LastTransitionTime.IsZero() { newCondition.LastTransitionTime = metav1.NewTime(time.Now()) } *conditions = append(*conditions, newCondition) return true } if existingCondition.Status != newCondition.Status { existingCondition.Status = newCondition.Status
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 22 01:13:33 UTC 2023 - 4.2K bytes - Viewed (0) -
plugin/pkg/admission/network/defaultingressclass/admission_test.go
defaultClassWithCreateTime1 := &networkingv1.IngressClass{ TypeMeta: metav1.TypeMeta{ Kind: "IngressClass", }, ObjectMeta: metav1.ObjectMeta{ Name: "default1", CreationTimestamp: metav1.NewTime(time.Date(2022, time.Month(1), 1, 0, 0, 0, 1, time.UTC)), Annotations: map[string]string{ networkingv1.AnnotationIsDefaultIngressClass: "true", }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 04 13:12:32 UTC 2023 - 7.7K bytes - Viewed (0) -
src/test/java/jcifs/tests/FileAttributesTest.java
f.setCreateTime(time); long newTime = f.createTime(); if ( newTime == orig ) { Assume.assumeTrue("Create time was not changed", false); } assertEquals(time, newTime); } catch ( SmbUnsupportedOperationException e ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/api/v1/pod/util_test.go
if ready { conditionStatus = v1.ConditionTrue } return &v1.Pod{ Status: v1.PodStatus{ Conditions: []v1.PodCondition{ { Type: v1.PodReady, LastTransitionTime: metav1.NewTime(now.Time.Add(-1 * time.Duration(beforeSec) * time.Second)), Status: conditionStatus, }, }, }, } } func TestIsPodAvailable(t *testing.T) { now := metav1.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 11:04:08 UTC 2023 - 32.1K bytes - Viewed (0) -
cmd/site-replication.go
func (c *SiteReplicationSys) startHealRoutine(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() healTimer := time.NewTimer(siteHealTimeInterval) defer healTimer.Stop() var maxRefreshDurationSecondsForLog float64 = 10 // 10 seconds.. for { select { case <-healTimer.C: c.RLock() enabled := c.enabled
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0)