Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 841 - 850 of 880 for resync (0.23 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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 replica
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.4K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top