Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 681 for limitTo (0.04 sec)

  1. cmd/erasure-healing-common.go

    			for k := range timeOccurrenceMap {
    				if k == nano {
    					// We add to ourself later
    					continue
    				}
    				diff := k - nano
    				if diff < 0 {
    					diff = -diff
    				}
    				// We are within the limit
    				if diff < groupNano {
    					timeOccurrenceMap[k]++
    				}
    			}
    		}
    		// Add ourself...
    		timeOccurrenceMap[nano]++
    	}
    
    	maxima = 0 // Counter for remembering max occurrence of elements.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. internal/event/target/kafka.go

    		loggerOnce: loggerOnce,
    		quitCh:     make(chan struct{}),
    	}
    	if target.store != nil {
    		if args.BatchSize > 1 {
    			target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{
    				Limit:         args.BatchSize,
    				Log:           loggerOnce,
    				Store:         queueStore,
    				CommitTimeout: args.BatchCommitTimeout,
    			})
    		}
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. docs/es/docs/tutorial/dependencies/classes-as-dependencies.md

    En ambos casos, tendrá:
    
    * Un parámetro de query `q` opcional que es un `str`.
    * Un parámetro de query `skip` que es un `int`, con un valor por defecto de `0`.
    * Un parámetro de query `limit` que es un `int`, con un valor por defecto de `100`.
    
    En ambos casos, los datos serán convertidos, validados, documentados en el esquema de OpenAPI, etc.
    
    ## Úsalo { #use-it }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

        }.also { expected ->
          assertThat(expected.message).isEqualTo("enclosed object too large")
        }
      }
    
      /** Object identifiers are nominally self-delimiting. Outrun the limit with one. */
      @Test fun `variable length long outruns limit`() {
        val bytes = "060229ffffff7f".decodeHex()
        assertFailsWith<ProtocolException> {
          Adapters.OBJECT_IDENTIFIER.fromDer(bytes)
        }.also { expected ->
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the life cycle methods.
     *
     * <h3>Usage Example</h3>
     *
     * <p>Here is a sketch of a service which crawls a website and uses the scheduling capabilities to
     * rate limit itself.
     *
     * {@snippet :
     * class CrawlingService extends AbstractScheduledService {
     *   private Set<Uri> visited;
     *   private Queue<Uri> toCrawl;
     *   protected void startUp() throws Exception {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.14.md

        * Custom apiservers built with the latest apiserver library will have the 100MB limit on the body of resource requests as well. The limit can be altered via ServerRunOptions.MaxRequestBodyBytes.
        * The body size limit does not apply to subresources like pods/proxy that proxy request content to another server.
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Mon Jun 14 22:06:39 UTC 2021
    - 271.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/MoreObjects.java

         * <p>After calling this method, you can keep adding more properties to later call toString()
         * again and get a more complete representation of the same object; but properties cannot be
         * removed, so this only allows limited reuse of the helper instance. The helper allows
         * duplication of properties (multiple name/value pairs with the same name can be added).
         */
        @Override
        public String toString() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  8. internal/event/target/elasticsearch.go

    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    
    		// Calculate a hash of the key for the id of the ES document.
    		// Id's are limited to 512 bytes in V7+, so we need to do this.
    		var keyHash string
    		{
    			key := eventData.S3.Bucket.Name + "/" + objectName
    			if target.client.isAtleastV7() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15K bytes
    - Viewed (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/Project.java

         * </ul>
         * <p>
         * The active profiles control various aspects of the build configuration including but not
         * limited to dependencies, plugins, properties, and build resources.
         *
         * @return a non-null, possibly empty list of active profiles for this project
         * @see Profile
         * @see #getEffectiveActiveProfiles()
         */
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Nov 07 13:11:07 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  10. docs/recipes.md

            String content;
          }
        ```
    
    ### Response Caching ([.kt][CacheResponseKotlin], [.java][CacheResponseJava])
    
    To cache responses, you'll need a cache directory that you can read and write to, and a limit on the cache's size. The cache directory should be private, and untrusted applications should not be able to read its contents!
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
Back to top