- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for gatherers (0.05 seconds)
-
cmd/metrics-v3.go
// Helper function to register a collector and return a gatherer for it. mustRegister := func(c ...prometheus.Collector) prometheus.Gatherer { subRegistry := prometheus.NewRegistry() for _, col := range c { subRegistry.MustRegister(col) } r.MustRegister(subRegistry) return subRegistry } // Register all collectors and create gatherers for them.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 02 00:55:27 GMT 2024 - 13.6K bytes - Click Count (0) -
cmd/metrics.go
registry := prometheus.NewRegistry() logger.CriticalIf(GlobalContext, registry.Register(minioVersionInfo)) logger.CriticalIf(GlobalContext, registry.Register(newMinioCollector())) gatherers := prometheus.Gatherers{ prometheus.DefaultGatherer, registry, } return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (0) -
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
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0) -
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
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 23.4K bytes - Click Count (0) -
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" \
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Wed Jan 28 22:41:17 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} private void assertEvents(String... events) { assertThat(stopwatch.readEventsAndClear()).isEqualTo(Arrays.toString(events)); } /** * 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. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} private void assertEvents(String... events) { assertThat(stopwatch.readEventsAndClear()).isEqualTo(Arrays.toString(events)); } /** * 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. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
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) {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Jan 08 17:58:59 GMT 2026 - 14.4K bytes - Click Count (0) -
src/cmd/asm/internal/asm/operand_test.go
return NewParser(ctxt, architecture, nil) } // tryParse executes parse func in panicOnError=true context. // parse is expected to call any parsing methods that may panic. // Returns error gathered from recover; nil if no parse errors occurred. // // For unexpected panics, calls t.Fatal. func tryParse(t *testing.T, parse func()) (err error) { panicOnError = true defer func() { panicOnError = false
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 23.9K bytes - Click Count (0) -
src/cmd/asm/internal/asm/asm.go
"cmd/internal/obj/arm64" "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) {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Mar 20 17:02:17 GMT 2026 - 27.5K bytes - Click Count (0)