Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 447 for Once (0.01 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top