Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 305 for duration (0.1 sec)

  1. internal/config/batch/batch.go

    type Config struct {
    	ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"`
    	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
    	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
    }
    
    // ExpirationWait returns the duration for which a batch expiration worker
    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/base/Internal.java

      static long toNanosSaturated(Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
        // durations longer than approximately +/- 292 years).
        try {
          return duration.toNanos();
        } catch (ArithmeticException tooBig) {
          return duration.isNegative() ? Long.MIN_VALUE : Long.MAX_VALUE;
        }
      }
    
      private Internal() {}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jan 11 14:30:06 UTC 2024
    - 2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/CacheBuilder.java

      @SuppressWarnings("GoodTime") // duration decomposition
      private static long toNanosSaturated(Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
        // durations longer than approximately +/- 292 years).
        try {
          return duration.toNanos();
        } catch (ArithmeticException tooBig) {
          return duration.isNegative() ? Long.MIN_VALUE : Long.MAX_VALUE;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  4. internal/http/listener_test.go

    		{[]string{"unknown-host:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}},                            // 4
    		{[]string{"localhost:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                              // 5
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/CacheBuilder.java

       */
      @J2ObjCIncompatible
      @GwtIncompatible // Duration
      @SuppressWarnings({
        "GoodTime", // Duration decomposition
        "Java7ApiChecker",
      })
      @IgnoreJRERequirement // No more dangerous than wherever the caller got the Duration from
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> expireAfterWrite(Duration duration) {
        return expireAfterWrite(toNanosSaturated(duration), NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  6. internal/s3select/parquet/reader.go

    				var duration time.Duration
    				// Only support UTC normalized timestamps.
    				if ts.IsAdjustedToUTC {
    					switch {
    					case ts.Unit.IsSetNANOS():
    						duration = time.Duration(val) * time.Nanosecond
    					case ts.Unit.IsSetMILLIS():
    						duration = time.Duration(val) * time.Millisecond
    					case ts.Unit.IsSetMICROS():
    						duration = time.Duration(val) * time.Microsecond
    					default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/testing/FakeTicker.java

        return this;
      }
    
      /**
       * Advances the ticker value by {@code duration}.
       *
       * @since 28.0
       */
      @GwtIncompatible
      @J2ktIncompatible
      @CanIgnoreReturnValue
      @SuppressWarnings("Java7ApiChecker") // guava-android can rely on library desugaring now.
      public FakeTicker advance(Duration duration) {
        return advance(duration.toNanos());
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. manifests/charts/base/files/crd-all.gen.yaml

                                      - message: must be a valid duration greater than
                                          1ms
                                        rule: duration(self) >= duration('1ms')
                                    maxConnectionDuration:
                                      description: The maximum duration of a connection.
                                      type: string
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Nov 01 16:23:52 UTC 2024
    - 805K bytes
    - Viewed (0)
  9. internal/config/batch/help.go

    		config.HelpKV{
    			Key:         ReplicationWorkersWait,
    			Description: `maximum sleep duration between objects to slow down batch replication operation` + defaultHelpPostfix(ReplicationWorkersWait),
    			Optional:    true,
    			Type:        "duration",
    		},
    		config.HelpKV{
    			Key:         KeyRotationWorkersWait,
    			Description: `maximum sleep duration between objects to slow down batch keyrotation operation` + defaultHelpPostfix(KeyRotationWorkersWait),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // java.time.Duration
      @ParametricNullness
      public static <V extends @Nullable Object> V getUninterruptibly(
          Future<V> future, Duration timeout) throws ExecutionException, TimeoutException {
        return getUninterruptibly(future, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
Back to top