Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 415 for queued (0.05 seconds)

  1. internal/event/target/webhook.go

    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			cancel()
    			return nil, fmt.Errorf("unable to initialize the queue store of Webhook `%s`: %w", id, err)
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb1/trans2/Trans2QueryPathInformationResponse.java

         * Constructs a Trans2QueryPathInformationResponse with the specified configuration and information level.
         *
         * @param config the SMB configuration
         * @param informationLevel the file information level being queried
         */
        public Trans2QueryPathInformationResponse(final Configuration config, final int informationLevel) {
            super(config);
            this.informationLevel = informationLevel;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  3. src/main/java/jcifs/netbios/Lmhosts.java

        private long lastModified = 1L;
        private int alt;
    
        /**
         * This is really just for {@link jcifs.netbios.UniAddress}. It does
         * not throw an {@link java.net.UnknownHostException} because this
         * is queried frequently and exceptions would be rather costly to
         * throw on a regular basis here.
         *
         * @param host the hostname to resolve
         * @param tc the CIFS context
         * @return resolved name, null if not found
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/graph/Graphs.java

    import java.util.ArrayDeque;
    import java.util.Collection;
    import java.util.Deque;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Objects;
    import java.util.Queue;
    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Static utility methods for {@link Graph}, {@link ValueGraph}, and {@link Network} instances.
     *
     * @author James Sexton
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 01:10:31 GMT 2026
    - 24.4K bytes
    - Click Count (0)
  5. cmd/metrics-v3-api.go

    	apiRejectedInvalidTotalMD = NewCounterMD(apiRejectedInvalidTotal,
    		"Total number of invalid requests", "type")
    
    	apiRequestsWaitingTotalMD = NewGaugeMD(apiRequestsWaitingTotal,
    		"Total number of requests in the waiting queue", "type")
    	apiRequestsIncomingTotalMD = NewGaugeMD(apiRequestsIncomingTotal,
    		"Total number of incoming requests", "type")
    
    	apiRequestsInFlightTotalMD = NewGaugeMD(apiRequestsInFlightTotal,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 9.4K bytes
    - Click Count (0)
  6. docs/es/docs/how-to/separate-openapi-schemas.md

    ## No Separar Esquemas { #do-not-separate-schemas }
    
    Ahora, hay algunos casos donde podrías querer tener el **mismo esquema para entrada y salida**.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 13:41:41 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  7. docs/pt/docs/how-to/custom-request-and-route.md

    # Request e classe APIRoute personalizadas { #custom-request-and-apiroute-class }
    
    Em alguns casos, você pode querer sobrescrever a lógica usada pelas classes `Request` e `APIRoute`.
    
    Em particular, isso pode ser uma boa alternativa para uma lógica em um middleware.
    
    Por exemplo, se você quiser ler ou manipular o corpo da requisição antes que ele seja processado pela sua aplicação.
    
    /// danger | Cuidado
    
    Isso é um recurso "avançado".
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  8. docs/contribute/concurrency.md

    #### Per-Connection Locks
    
    Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
    
    The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-CacheControlCommon.kt

            parameter = null
          } else {
            pos++ // Consume '='.
            pos = value.indexOfNonWhitespace(pos)
    
            if (pos < value.length && value[pos] == '\"') {
              // Quoted string.
              pos++ // Consume '"' open quote.
              val parameterStart = pos
              pos = value.indexOf('"', pos)
              parameter = value.substring(parameterStart, pos)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.3K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Set<Object> actualValues = ImmutableSet.copyOf(map.values());
        assertThat(actualValues).isEqualTo(expectedValues);
      }
    
      /** Lookups on the map view shouldn't impact the recency queue. */
      public void testAsMapRecency() {
        CacheBuilder<Object, Object> builder =
            createCacheBuilder().concurrencyLevel(1).maximumSize(SMALL_MAX_SIZE);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
Back to Top