- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,392 for pool (0.17 sec)
-
cmd/admin-router.go
adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}") // Rebalance operations adminRouter.Methods(http.MethodPost).Path(adminVersion + "/rebalance/start").HandlerFunc(adminMiddleware(adminAPI.RebalanceStart, traceAllFlag))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/data-usage.go
// No need to fail upon Update() error, fallback to old value. cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func() (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets { // Load bucket usage prefixes ctx, done := context.WithTimeout(context.Background(), 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.6K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/crd-all.gen.yaml
pool for the upstream service that can be ejected. format: int32 type: integer minHealthPercent: description: Outlier detection will be enabled as long as the associated load balancing pool has at least
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
docs/distributed/README.md
> **NOTE:** **Each pool you add must have the same erasure coding parity configuration as the original pool, so the same data redundancy SLA is maintained.**
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/logging/testdata/logging.txt
http: warning http2: warning hystrix: warning init: warning io: warning jwt: warning kafka: warning lua: warning main: warning misc: warning mongo: warning quic: warning pool: warning rbac: warning redis: warning router: warning runtime: warning stats: warning secret: warning tap: warning testing: warning thrift: warning tracing: warning
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 02 13:47:26 GMT 2019 - 715 bytes - Viewed (0) -
docs/features/connections.md
1. It uses the URL and configured OkHttpClient to create an **address**. This address specifies how we'll connect to the webserver. 2. It attempts to retrieve a connection with that address from the **connection pool**. 3. If it doesn't find a connection in the pool, it selects a **route** to attempt. This usually means making a DNS request to get the server's IP addresses. It then selects a TLS version and proxy server if necessary.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Viewed (0) -
fastapi/concurrency.py
# has its own internal pool (e.g. a database connection pool) # to avoid this we let __exit__ run without a capacity limit # since we're creating a new limiter for each call, any non-zero limit # works (1 is arbitrary) exit_limiter = CapacityLimiter(1) try: yield await run_in_threadpool(cm.__enter__) except Exception as e: ok = bool( await anyio.to_thread.run_sync(
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Mon Dec 25 17:57:35 GMT 2023 - 1.4K bytes - Viewed (0) -
internal/grid/handlers.go
if r != rZero { if rc, ok := any(r).(Recycler); ok { rc.Recycle() } } } } pool := sync.Pool{ New: func() interface{} { return newRT() }, } return func() RT { return pool.Get().(RT) }, func(r RT) { if r != rZero { pool.Put(r) } } } // NewSingleHandler creates a typed handler that can provide Marshal/Unmarshal.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
args: strings.Split("log ztunnel-9v7nw --level ztunnel:::pool:debug", " "), expectedString: "unrecognized logging level: pool:debug", wantException: true, }, { // logger name valid and logging level valid execClientConfig: loggingConfig, args: strings.Split("log ztunnel-9v7nw --level ztunnel::pool:debug", " "), expectedString: "", wantException: false, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/graph/NetworkMutationTest.java
@RunWith(JUnit4.class) public final class NetworkMutationTest { private static final int NUM_TRIALS = 5; private static final int NUM_NODES = 20; private static final int NUM_EDGES = 100; private static final int NODE_POOL_SIZE = 1000; // must be >> NUM_NODES @Test public void directedNetwork() { testNetworkMutation(NetworkBuilder.directed()); } @Test public void undirectedNetwork() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 10 19:42:18 GMT 2024 - 4.5K bytes - Viewed (0)