Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for gatherers (0.04 sec)

  1. cmd/metrics-v3-handler.go

    					continue
    				}
    				unLocker := bmg.LockAndSetBuckets(buckets)
    				defer unLocker()
    			}
    			gatherers = append(gatherers, gatherer)
    		}
    	}
    
    	if len(gatherers) == 0 {
    		return notFoundHandler
    	}
    
    	return promhttp.HandlerFor(prometheus.Gatherers(gatherers), h.opts)
    }
    
    // ServeHTTP - implements http.Handler interface.
    //
    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. cmd/metrics-v2.go

    	gatherers := prometheus.Gatherers{
    		registry,
    	}
    
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    		if ok {
    			tc.FuncName = funcName
    			tc.ResponseRecorder.LogErrBody = true
    		}
    
    		mfs, err := gatherers.Gather()
    		if err != nil && len(mfs) == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  3. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/cisupport/CIInfo.java

     * under the License.
     */
    package org.apache.maven.api.cli.cisupport;
    
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * CI support: this class contains gathered information and more from CI that Maven process runs on.
     *
     * @since 4.0.0
     */
    public interface CIInfo {
        /**
         * Short distinct name of CI system: "GH", "Jenkins", etc.
         */
        @Nonnull
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Sun Apr 13 18:50:07 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

      /**
       * Returns an OkHttpClient for tests to use as a starting point.
       *
       * The returned client installs a default event listener that gathers debug information. This will
       * be logged if the test fails.
       *
       * This client is also configured to be slightly more deterministic, returning a single IP
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/lang/GenericsUtil.java

            for (int i = 0; i < interfaces.length; ++i) {
                gatherTypeVariables(interfaces[i], interfaceTypes[i], map);
            }
    
            return map;
        }
    
        /**
         * Gathers the type variables and type arguments of the specified parameterized type (class or interface)
         * and adds them to the given map.
         *
         * @param clazz
         *            the class to analyze
         * @param type
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 23.4K bytes
    - Viewed (0)
  6. ci/official/utilities/code_check_full.bats

    }
    
    # Do a bazel query specifically for the licenses checker. It searches for
    # targets matching the provided query, which start with // or @ but not
    # //tensorflow (so it looks for //third_party, //external, etc.), and then
    # gathers the list of all packages (i.e. directories) which contain those
    # targets.
    license_query() {
     bazel cquery --experimental_cc_shared_library "$1" --keep_going \
      | grep -e "^//" -e "^@" \
      | grep -E -v "^//tensorflow" \
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Wed Aug 06 20:43:08 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  9. src/cmd/cgo/ast.go

    	}
    	return ast1
    }
    
    func sourceLine(n ast.Node) int {
    	return fset.Position(n.Pos()).Line
    }
    
    // ParseGo populates f with information learned from the Go source code
    // which was read from the named file. It gathers the C preamble
    // attached to the import "C" comment, a list of references to C.xxx,
    // a list of exported functions, and the actual AST, to be rewritten and
    // printed.
    func (f *File) ParseGo(abspath string, src []byte) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Oct 14 15:47:06 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/asm.go

    	"cmd/internal/obj"
    	"cmd/internal/obj/ppc64"
    	"cmd/internal/obj/riscv"
    	"cmd/internal/obj/x86"
    	"cmd/internal/sys"
    )
    
    // TODO: configure the architecture
    
    var testOut *strings.Builder // Gathers output when testing.
    
    // append adds the Prog to the end of the program-thus-far.
    // If doLabel is set, it also defines the labels collect for this Prog.
    func (p *Parser) append(prog *obj.Prog, cond string, doLabel bool) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 05 17:31:25 UTC 2025
    - 26.2K bytes
    - Viewed (0)
Back to top