- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 300 for brokers (0.06 seconds)
-
cmd/batch-expire.go
oi, ok := oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)] return oi, ok } func batchObjsForDelete(ctx context.Context, r *BatchJobExpire, ri *batchJobInfo, job BatchJobRequest, api ObjectLayer, wk *workers.Workers, expireCh <-chan []expireObjInfo) { vc, _ := globalBucketVersioningSys.Get(r.Bucket) retryAttempts := job.Expire.Retry.Attempts if retryAttempts <= 0 { retryAttempts = batchExpireJobDefaultRetries }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 22 11:16:32 GMT 2025 - 23K bytes - Click Count (0) -
guava/src/com/google/common/collect/AbstractBiMap.java
inverse.delegate.clear(); Entry<K, V> broken = null; Iterator<Entry<K, V>> itr = this.delegate.entrySet().iterator(); while (itr.hasNext()) { Entry<K, V> entry = itr.next(); K k = entry.getKey(); V v = entry.getValue(); K conflict = inverse.delegate.putIfAbsent(v, k); if (conflict != null) { broken = entry;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 14.3K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/testing/EqualsTesterTest.java
} catch (AssertionFailedError e) { assertErrorMessage(e, "bar [group 1, item 2] must be Object#equals to foo [group 1, item 1]"); return; } fail("should failed because symmetry is broken"); } public void testTransitivityBrokenInEqualityGroup() { EqualsTester tester = new EqualsTester() .addEqualityGroup( named("foo").addPeers("bar", "baz"),
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 13.1K bytes - Click Count (0) -
docs/uk/docs/deployment/docker.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:27:41 GMT 2026 - 44.2K bytes - Click Count (0) -
internal/config/heal/help.go
Optional: true, Type: "int", }, config.HelpKV{ Key: DriveWorkers, Description: `the number of workers per drive to heal a new disk replacement` + defaultHelpPostfix(DriveWorkers), Optional: true, Type: "int", }, }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 1.8K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchJavaPlugin.java
toStringable(() -> Boolean.toString(VersionProperties.isElasticsearchSnapshot())) ); }); project.getPluginManager().apply("nebula.info-broker"); project.getPluginManager().apply("nebula.info-basic"); project.getPluginManager().apply("nebula.info-java"); project.getPluginManager().apply("nebula.info-jar"); }
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Sep 27 16:04:42 GMT 2021 - 7.3K bytes - Click Count (0) -
ci/README.md
and deploy TensorFlow. This folder is typically used by continuous integration (CI) tools to build and test TensorFlow whenever there is a change to the code. This folder is broken into subfolders that represent the level of support
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Tue Jun 06 21:00:01 GMT 2023 - 825 bytes - Click Count (0) -
guava-testlib/test/com/google/common/testing/EqualsTesterTest.java
} catch (AssertionFailedError e) { assertErrorMessage(e, "bar [group 1, item 2] must be Object#equals to foo [group 1, item 1]"); return; } fail("should failed because symmetry is broken"); } public void testTransitivityBrokenInEqualityGroup() { EqualsTester tester = new EqualsTester() .addEqualityGroup( named("foo").addPeers("bar", "baz"),
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 13.1K bytes - Click Count (0) -
internal/config/notify/help.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 19.2K bytes - Click Count (0) -
internal/logger/help.go
Optional: true, Type: "sentence", }, } HelpKafka = config.HelpKVS{ config.HelpKV{ Key: KafkaBrokers, Description: "comma separated list of Kafka broker addresses", Type: "csv", }, config.HelpKV{ Key: KafkaTopic, Description: "Kafka topic used for bucket notifications", Optional: true, Type: "string", },
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Sep 11 22:20:42 GMT 2024 - 7.4K bytes - Click Count (0)