- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,397 for pool (0.14 sec)
-
manifests/charts/base/crds/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 Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
docs/metrics/prometheus/alerts.md
for: 5m labels: severity: critical annotations: summary: "Instance {{ $labels.server }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }}" description: "MinIO instance {{ $labels.server }} of job {{ $labels.job }} has lost quorum on pool {{ $labels.pool }} on set {{ $labels.set }} for more than 5 minutes." ``` ## Verify the configuration and alerts
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 20:53:59 GMT 2024 - 4.4K bytes - Viewed (0) -
scripts/docs.py
shutil.rmtree(site_path, ignore_errors=True) langs = [lang.name for lang in get_lang_paths() if lang.is_dir()] cpu_count = os.cpu_count() or 1 process_pool_size = cpu_count * 4 typer.echo(f"Using process pool size: {process_pool_size}") with Pool(process_pool_size) as p: p.map(build_lang, langs) @app.command() def update_languages() -> None: """
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Mon Jan 22 19:26:14 GMT 2024 - 10.9K bytes - Viewed (1) -
cmd/endpoint.go
} sort.Slice(nodes, func(i, j int) bool { return nodes[i].Host < nodes[j].Host }) return } // GetPoolIdx return pool index func (l EndpointServerPools) GetPoolIdx(pool string) int { for id, ep := range globalEndpoints { if ep.CmdLine != pool { continue } return id } return -1 } // GetLocalPoolIdx returns the pool which endpoint belongs to locally.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
int tasksPerThread = 10; int nTasks = nThreads * tasksPerThread; ExecutorService pool = Executors.newFixedThreadPool(nThreads); ImmutableList<String> keys = ImmutableList.of("a", "b", "c"); try { List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); for (int i = 0; i < nTasks; i++) { futures.add(pool.submit(new MutateTask(multiset, keys))); } int[] deltas = new int[3];
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 5.8K bytes - Viewed (0) -
internal/handlers/forwarder.go
} return f } type bufPool struct { sz int pool sync.Pool } func (b *bufPool) Put(buf []byte) { if cap(buf) < b.sz || cap(buf) > b.sz*2 { // Buffer too small or will likely leak memory after being expanded. // Drop it. return } b.pool.Put(&buf) } func (b *bufPool) Get() []byte { bufp := b.pool.Get().(*[]byte) return (*bufp)[:b.sz] }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
istioctl/pkg/xds/google.go
if !ok { return nil, errors.New(`field "spec" is not a map`) } var mem hubMembership mem.WorkloadIdentityPool, ok = spec["workload_identity_pool"].(string) if !ok { return nil, errors.New(`field "spec.workload_identity_pool" is not a string`) } return &mem, nil } func mcpDialOptions(ctx context.Context, gcpProject string, k8sCreds credentials.PerRPCCredentials) ([]grpc.DialOption, error) {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
.build() val request = Request(server.url("/")) val response1 = client.newCall(request).execute() assertThat(response1.body.string()).isEqualTo("a") // Give the thread pool a chance to evict. Thread.sleep(500) val response2 = client.newCall(request).execute() assertThat(response2.body.string()).isEqualTo("b") assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/metacache-marker.go
continue } case "id": o.ID = kv[1] case "return": o.ID = mustGetUUID() o.Create = true case "p": // pool v, err := strconv.ParseInt(kv[1], 10, 64) if err != nil { o.ID = mustGetUUID() o.Create = true continue } o.pool = int(v) case "s": // set v, err := strconv.ParseInt(kv[1], 10, 64) if err != nil { o.ID = mustGetUUID() o.Create = true
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.5K bytes - Viewed (0) -
interfaces.go
type Plugin interface { Name() string Initialize(*DB) error } type ParamsFilter interface { ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{}) } // ConnPool db conns pool interface type ConnPool interface { PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sat Aug 19 13:33:31 GMT 2023 - 2.2K bytes - Viewed (0)