- Sort Score
- Num 10 results
- Language All
Results 281 - 290 of 415 for queued (0.05 seconds)
-
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) -
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) -
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 foundCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.3K bytes - Click Count (0) -
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 SextonCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 01:10:31 GMT 2026 - 24.4K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-CacheControlCommon.kt
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) -
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)