Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 426 for NOW (0.18 sec)

  1. internal/bucket/lifecycle/lifecycle_test.go

    				},
    			},
    		},
    	}
    
    	now := time.Now().UTC()
    
    	obj1 := ObjectOpts{
    		Name:     "obj1",
    		IsLatest: true,
    		ModTime:  now,
    	}
    
    	obj2 := ObjectOpts{
    		Name:    "obj2",
    		ModTime: now,
    	}
    
    	// Go back seven days in the past
    	now = now.Add(7 * 24 * time.Hour)
    
    	evt := lc.eval(obj1, now)
    	if evt.Action != TransitionAction {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 45.6K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/lifecycle.go

    }
    
    // Eval returns the lifecycle event applicable now.
    func (lc Lifecycle) Eval(obj ObjectOpts) Event {
    	return lc.eval(obj, time.Now().UTC())
    }
    
    // eval returns the lifecycle event applicable at the given now. If now is the
    // zero value of time.Time, it returns the upcoming lifecycle event.
    func (lc Lifecycle) eval(obj ObjectOpts, now time.Time) Event {
    	var events []Event
    	if obj.ModTime.IsZero() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 09 06:41:22 GMT 2024
    - 17K bytes
    - Viewed (0)
  3. doc/next/6-stdlib/99-minor/net/63116.md

    The [DNSError] type now wraps errors caused by timeouts or cancellation.
    For example, `errors.Is(someDNSErr, context.DeadlineExceedeed)`
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Apr 24 13:37:36 GMT 2024
    - 198 bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    	}
    
    	bucket := "bucket"
    	obj := "obj-1"
    	now := time.Now()
    	meta := BucketMetadata{
    		Name:                      bucket,
    		Created:                   now,
    		LifecycleConfigXML:        lcXML,
    		VersioningConfigXML:       vcfgXML,
    		VersioningConfigUpdatedAt: now,
    		LifecycleConfigUpdatedAt:  now,
    		lifecycleConfig:           &lc,
    		versioningConfig:          &vcfg,
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/helper/SystemHelperTest.java

            final long now = System.currentTimeMillis();
            assertTrue(now + ">=" + current + " : " + (now - current), now >= current);
            assertTrue(now - 1000 + "<" + current + " : " + (current - now + 1000), now - 1000 < current);
        }
    
        public void test_getLogFilePath() {
    Java
    - Registered: Mon Apr 29 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 18.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/LocalCache.java

              ReferenceEntry<K, V> e = getEntry(key, hash);
              if (e != null) {
                long now = map.ticker.read();
                V value = getLiveValue(e, now);
                if (value != null) {
                  recordRead(e, now);
                  statsCounter.recordHits(1);
                  return scheduleRefresh(e, key, hash, value, now, loader);
                }
                ValueReference<K, V> valueReference = e.getValueReference();
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
  7. internal/config/identity/plugin/config.go

    	ticker := time.NewTicker(healthCheckInterval)
    	defer ticker.Stop()
    
    	for {
    		select {
    		case <-ticker.C:
    			now := time.Now()
    			isConnected := o.checkConnectivity(o.shutdownCtx)
    			if isConnected {
    				o.serviceMetrics.setConnSuccess(now)
    			} else {
    				o.serviceMetrics.setConnFailure(now)
    			}
    		case <-o.shutdownCtx.Done():
    			return
    		}
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.3K bytes
    - Viewed (3)
  8. cmd/tier-last-day-stats.go

    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    		t = time.Now()
    	}
    
    	since := t.Sub(l.UpdatedAt).Hours()
    	// within the hour since l.UpdatedAt
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/LocalCache.java

              ReferenceEntry<K, V> e = getEntry(key, hash);
              if (e != null) {
                long now = map.ticker.read();
                V value = getLiveValue(e, now);
                if (value != null) {
                  recordRead(e, now);
                  statsCounter.recordHits(1);
                  return scheduleRefresh(e, key, hash, value, now, loader);
                }
                ValueReference<K, V> valueReference = e.getValueReference();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 144.7K bytes
    - Viewed (0)
  10. maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                    String now = versioningRef.getLastUpdated();
                    if (lastUpdated != null && now != null && now.compareTo(lastUpdated) < 0) {
                        getLogger()
                                .warn("The last updated timestamp in " + metadataFile + " refers to the future (now = "
                                        + now
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 18.9K bytes
    - Viewed (0)
Back to top