- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 447 for Once (0.01 sec)
-
cmd/metrics-v3-handler.go
opts promhttp.HandlerOpts auth func(http.Handler) http.Handler metricsData *metricsV3Collection } var ( globalMetricsV3CollectorPaths []collectorPath globalMetricsV3Once sync.Once ) func newMetricsV3Server(auth func(h http.Handler) http.Handler) *metricsV3Server { registry := prometheus.NewRegistry() metricGroups := newMetricGroups(registry) globalMetricsV3Once.Do(func() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 7.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
*/ fun cancel() fun interface Factory { /** * Creates a new web socket and immediately returns it. Creating a web socket initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must either close or cancel the returned web socket when it is no longer * in use. */ fun newWebSocket( request: Request,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.3K bytes - Viewed (0) -
docs/bucket/replication/README.md
The replication configuration in use on a bucket can be viewed using the `mc replicate export alias/bucket` command.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.3K bytes - Viewed (0) -
cmd/format-erasure.go
newFormat.ID = deploymentID } hostCount[disk.Hostname()]++ formats[i*setDriveCount+j] = newFormat } var once sync.Once for host, count := range hostCount { if count > wantAtMost { if host == "" { host = "local" } once.Do(func() { if len(hostCount) == 1 { return } logger.Info(" * Set %v:", i+1) for j := range setDriveCount {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 23.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/MapTestSuiteBuilder.java
@Override protected List<TestSuite> createDerivedSuites( FeatureSpecificTestSuiteBuilder< ?, ? extends OneSizeTestContainerGenerator<Map<K, V>, Entry<K, V>>> parentBuilder) { // TODO: Once invariant support is added, supply invariants to each of the // derived suites, to check that mutations to the derived collections are // reflected in the underlying map.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 11K bytes - Viewed (0) -
docs/metrics/prometheus/README.md
``` #### 3.2 Public Prometheus config If Prometheus endpoint authentication type is set to `public`. Following prometheus config is sufficient to start scraping metrics data from MinIO. This can be collected from any server once per collection. ##### Cluster ```yaml scrape_configs: - job_name: minio-job metrics_path: /minio/v2/metrics/cluster scheme: http static_configs: - targets: ['localhost:9000'] ```
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.1K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hasher.java
@ParametricNullness T instance, Funnel<? super T> funnel); /** * Computes a hash code based on the data that have been provided to this hasher. The result is * unspecified if this method is called more than once on the same instance. */ HashCode hash(); /** * {@inheritDoc} * * @deprecated This returns {@link Object#hashCode()}; you almost certainly mean to call {@code * hash().asInt()}.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 5.5K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/SamrPolicyHandleTest.java
SamrPolicyHandle handle = new SamrPolicyHandle(mockHandle, server, access); handle.close(); // First close handle.close(); // Second close // Verify sendrecv for close was called only once verify(mockHandle, times(1)).sendrecv(any(MsrpcSamrCloseHandle.class)); } @Test void testClose_SmbExceptionOnClose() throws IOException {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
* may not occur at all. However, despite these limitations, * observed contention rates are typically low in these cases. * * It is possible for a Cell to become unused when threads that * once hashed to it terminate, as well as in the case where * doubling the table causes no thread to hash to it under * expanded mask. We do not try to detect or remove such cells,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jan 15 22:17:15 UTC 2025 - 11.4K bytes - Viewed (0) -
guava/src/com/google/common/hash/LittleEndianByteArray.java
* @return a long of a concatenated 8 bytes */ static long load64Safely(byte[] input, int offset, int length) { long result = 0; // Due to the way we shift, we can stop iterating once we've run out of data, the rest // of the result already being filled with zeros. // This loop is critical to performance, so please check HashBenchmark if altering it. int limit = min(length, 8);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 03:49:18 UTC 2025 - 12.3K bytes - Viewed (0)