Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Collect (0.43 sec)

  1. cmd/metrics-v2.go

    // Describe sends the super-set of all possible descriptors of metrics
    func (c *minioBucketCollector) Describe(ch chan<- *prometheus.Desc) {
    	ch <- c.desc
    }
    
    // Collect is called by the Prometheus registry when collecting metrics.
    func (c *minioBucketCollector) Collect(out chan<- prometheus.Metric) {
    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.collect.ImmutableSet;
    import com.google.common.collect.Iterables;
    import com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder;
    import com.google.common.collect.testing.TestStringMapGenerator;
    import com.google.common.collect.testing.features.CollectionFeature;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 110.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                        logger.debug(() -> "Refreshed " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))));
                    }
                }
    
                @Override
                public void onFailure(final Exception e) {
                    logger.error(() -> "Failed to refresh " + stream(indices).get(stream -> stream.collect(Collectors.joining(", "))), e);
                }
            });
    
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  4. api/maven-api-model/src/main/mdo/maven.mdo

         * @see java.lang.Object#toString()
         */
        public String toString() {
            return "PatternSet [" +
                "includes: {" + getIncludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}, " +
                "excludes: {" + getExcludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}]";
        }
                ]]>
              </code>
            </codeSegment>
          </codeSegments>
        </class>
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Aug 07 14:32:16 UTC 2025
    - 132.7K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.StorageInfoAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	storageInfo := objectAPI.StorageInfo(ctx, true)
    
    	// Collect any disk healing.
    	healing, _ := getAggregatedBackgroundHealState(ctx, nil)
    	healDisks := make(map[string]struct{}, len(healing.HealDisks))
    	for _, disk := range healing.HealDisks {
    		healDisks[disk] = struct{}{}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    import com.google.common.collect.FluentIterable;
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.AsyncCombiningCallable;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.CombiningCallable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    	info.UserStats = make(map[string]map[string]srUserStatsSummary)
    	info.GroupStats = make(map[string]map[string]srGroupStatsSummary)
    	info.ILMExpiryRulesStats = make(map[string]map[string]srILMExpiryRuleStatsSummary)
    	// collect user policy mapping replication status across sites
    	if opts.Users || opts.Entity == madmin.SRUserEntity {
    		for u, pslc := range userPolicyStats {
    			if len(info.UserStats[u]) == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ClosingFuture.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.annotations.VisibleForTesting;
    import com.google.common.collect.FluentIterable;
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.AsyncCombiningCallable;
    import com.google.common.util.concurrent.ClosingFuture.Combiner.CombiningCallable;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.4.md

    * Kubelet: Add image cache. ([#38375](https://github.com/kubernetes/kubernetes/pull/38375), [@Random-Liu](https://github.com/Random-Liu))
    * Collect logs for dead kubelets too ([#37671](https://github.com/kubernetes/kubernetes/pull/37671), [@mtaufen](https://github.com/mtaufen))
    
    
    
    # v1.4.7
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        enableTls()
        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
    
        // Make a first request without certificate pinning. Use it to collect certificates to pin.
        val request1 = Request.Builder().url(server.url("/")).build()
        val response1 = client.newCall(request1).execute()
        val certificatePinnerBuilder = CertificatePinner.Builder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
Back to top