Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 92 for atMost (0.1 sec)

  1. internal/event/target/nats.go

    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. internal/event/target/elasticsearch.go

    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/collect/TreeRangeSetTest.java

            .containsExactly(Range.lessThan(3), Range.greaterThan(3))
            .inOrder();
      }
    
      public void testRemoveMiddle() {
        TreeRangeSet<Integer> rangeSet = TreeRangeSet.create();
        rangeSet.add(Range.atMost(6));
        rangeSet.remove(Range.closedOpen(3, 4));
        testInvariants(rangeSet);
        assertThat(rangeSet.asRanges())
            .containsExactly(Range.lessThan(3), Range.closed(4, 6))
            .inOrder();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    	info.MaxPolicies = len(policyStats)
    	info.MaxILMExpiryRules = len(ilmExpiryRuleStats)
    	return
    }
    
    // isReplicated returns true if count of replicated matches the number of
    // sites and there is atmost one unique entry in the set.
    func isReplicated(cntReplicated, total int, valSet set.StringSet) bool {
    	if cntReplicated > 0 && cntReplicated < total {
    		return false
    	}
    	if len(valSet) > 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

        // below the values of characters in surrogate pairs, this cannot occur.
        // This approach does mean that we break out of the fast path code in cases
        // where we don't strictly need to, but this situation will almost never
        // occur in practice.
        if (safeMin >= Character.MIN_HIGH_SURROGATE) {
          // The safe range is empty or the all safe code points lie in or above the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

          // to ensure the first test of either value will (almost certainly) fail.
          safeMax = Character.MIN_VALUE;
          safeMin = Character.MAX_VALUE;
        }
        this.safeMin = safeMin;
        this.safeMax = safeMax;
      }
    
      /*
       * This is overridden to improve performance. Rough benchmarking shows that this almost doubles
       * the speed when processing strings that do not require any escaping.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 18 20:55:09 UTC 2022
    - 6.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/util/LogStream.java

     */
    
    package jcifs.smb1.util;
    
    import java.io.PrintStream;
    
    /**
    0 - nothing
    1 - critical [default]
    2 - basic info can be logged under load
    3 - almost everything
    N - debugging
     */
    
    public class LogStream extends PrintStream {
    
        private static LogStream inst;
    
        public static int level = 1;
    
        public LogStream( PrintStream stream ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 1.6K bytes
    - Viewed (0)
  8. ci/official/containers/linux_arm64/build.sh

      fi
    fi
    
    AR_IMAGE_PATH="us-central1-docker.pkg.dev/tensorflow-sigs/tensorflow/build-arm64"
    
    # Build for both JAX and TF usage.  We do these in one place because they share
    # almost all of the same cache layers
    export DOCKER_BUILDKIT=1
    for target in jax tf; do
      AR_IMAGE="$AR_IMAGE_PATH:$target-$TAG"
      docker pull "$AR_IMAGE" || true
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 01 15:44:57 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  9. docs/en/docs/how-to/graphql.md

    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 22:39:38 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/NullnessCasts.java

       * ParametricNullness parametric nullness}. If a type parameter instead ranges over only non-null
       * types (or if the type is a non-variable type, like {@code String}), then code should almost
       * never use this method, preferring instead to call {@code requireNonNull} so as to benefit from
       * its runtime check.
       *
       * <p>An example use case for this method is in implementing an {@code Iterator<T>} whose {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 10 20:36:34 UTC 2022
    - 3.5K bytes
    - Viewed (0)
Back to top