- Sort Score
- Num 10 results
- Language All
Results 841 - 850 of 880 for resync (0.23 seconds)
-
docs/zh/docs/tutorial/bigger-applications.md
{* ../../docs_src/bigger_applications/app_an_py310/routers/items.py hl[5:10,16,21] title["app/routers/items.py"] *} 由于每个*路径操作*的路径都必须以 `/` 开头,例如: ```Python hl_lines="1" @router.get("/{item_id}") async def read_item(item_id: str): ... ``` ...前缀不能以 `/` 作为结尾。 因此,本例中的前缀为 `/items`。 我们还可以添加一个 `tags` 列表和额外的 `responses` 列表,这些参数将应用于此路由器中包含的所有*路径操作*。Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:06:37 GMT 2026 - 19.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertStillOpen(closeable1); assertClosed(closeable2, closeable3); } // We don't need to test the happy case for SuccessfulCombiner.call(Async) because it's the same // as Combiner. public void testWhenAllSucceed_call_failedInput() throws Exception { assertFinallyFailsWithException( ClosingFuture.whenAllSucceed(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertStillOpen(closeable1); assertClosed(closeable2, closeable3); } // We don't need to test the happy case for SuccessfulCombiner.call(Async) because it's the same // as Combiner. public void testWhenAllSucceed_call_failedInput() throws Exception { assertFinallyFailsWithException( ClosingFuture.whenAllSucceed(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableBiMap.java
* as implementation details. * * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the * bimap and its inverse in sync during serialization, the way AbstractBiMap does. */ @J2ktIncompatible // serialization private static final class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 22.7K bytes - Click Count (0) -
internal/config/notify/parse.go
clusterIDEnv = clusterIDEnv + config.Default + k } natsArgs.Streaming.Enable = streamingEnabled natsArgs.Streaming.ClusterID = env.Get(clusterIDEnv, kv.Get(target.NATSStreamingClusterID)) natsArgs.Streaming.Async = env.Get(asyncEnv, kv.Get(target.NATSStreamingAsync)) == config.EnableOn natsArgs.Streaming.MaxPubAcksInflight = maxPubAcksInflight } if err = natsArgs.Validate(); err != nil { return nil, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 47.5K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.25.md
- In "large" clusters, kube-proxy in iptables mode will now sometimes leave unused rules in iptables for a while (up to `--iptables-sync-period`) before deleting them. This improves performance by not requiring it to check for stale rules on every sync. (In smaller clusters, it will still remove unused rules immediately once they are no longer used.)
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Mon May 06 09:23:20 GMT 2024 - 419.1K bytes - Click Count (0) -
cmd/peer-rest-client.go
package cmd import ( "context" "encoding/gob" "encoding/hex" "encoding/json" "errors" "fmt" "io" "net/url" "strconv" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/bucket/bandwidth" "github.com/minio/minio/internal/grid" xhttp "github.com/minio/minio/internal/http"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
internal/bucket/replication/replication_test.go
// using config 4 - with replica modification sync disabled. {ObjectOpts{Name: "xy/c5test", UserTags: "k1=v1", Replica: true}, cfgs[4], false}, // 39. replica syncing disabled, this object is a replicaCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
() -> { AbstractFuture<String> future = setFutureFuture.get(); setFutureSetSuccess.set(currentFuture.get().setFuture(future)); setFutureCompletionSuccess.set(future.set("hello-async-world")); awaitUnchecked(barrier); }; Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable = () -> { try {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
src/cmd/asm/internal/asm/testdata/amd64enc.s
AESDECLAST X11, X11 // 66450f38dfdb AESENC (BX), X2 // 660f38dc13 AESENC (R11), X2 // 66410f38dc13 AESENC X2, X2 // 660f38dcd2 AESENC X11, X2 // 66410f38dcd3 AESENC (BX), X11 // 66440f38dc1b AESENC (R11), X11 // 66450f38dc1b AESENC X2, X11 // 66440f38dcda
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Oct 08 21:38:44 GMT 2021 - 581.9K bytes - Click Count (1)