- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 582 for observ (0.14 sec)
-
maven-core/src/main/java/org/apache/maven/execution/ProjectExecutionListener.java
* under the License. */ package org.apache.maven.execution; import org.apache.maven.lifecycle.LifecycleExecutionException; /** * <p> * Extension point that allows build extensions observe and possibly veto project build execution. * </p> * <strong>Note:</strong> This interface is part of work in progress and can be changed or removed without notice. * * @see ExecutionListener * @see MojoExecutionListener
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/metrics.go
func RecordRequestLatency(ctx context.Context, code string, latency float64) { requestLatency.WithContext(ctx).WithLabelValues(code).Observe(latency)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 29 07:49:14 UTC 2021 - 2.1K bytes - Viewed (0) -
src/sync/pool.go
// In pinSlow we store to local and then to localSize, here we load in opposite order. // Since we've disabled preemption, GC cannot happen in between. // Thus here we must observe local at least as large localSize. // We can observe a newer/larger local, it is fine (we must observe its zero-initialized-ness). s := runtime_LoadAcquintptr(&p.localSize) // load-acquire l := p.local // load-consume if uintptr(pid) < s {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (1) -
pkg/kubelet/metrics/metrics_test.go
imageSize := int64(dp[0]) duration := dp[1] t.Log(imageSize, duration) t.Log(GetImageSizeBucket(uint64(imageSize))) ImagePullDuration.WithLabelValues(GetImageSizeBucket(uint64(imageSize))).Observe(duration) } wants, err := os.Open("testdata/image_pull_duration_metric") defer func() { if err := wants.Close(); err != nil { t.Error(err) } }() if err != nil { t.Fatal(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 00:30:31 UTC 2024 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/metrics.go
type validationMetrics struct { RatchetingTime *metrics.Histogram } // ObserveRatchetingTime records the time spent on ratcheting func (m *validationMetrics) ObserveRatchetingTime(d time.Duration) { m.RatchetingTime.Observe(d.Seconds()) } // Reset resets the metrics. This is meant to be used for testing. Panics // if the metrics cannot be re-registered. Returns all the reset metrics func (m *validationMetrics) Reset() []metrics.Registerable {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:57:34 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/library/test.go
} if t.version >= 1 { options = append(options, cel.Function("test", cel.Overload("test", []*cel.Type{}, cel.BoolType, cel.FunctionBinding(func(args ...ref.Val) ref.Val { // Return false here so tests can observe which version of the function is registered // Actual function libraries must not break backward compatibility return types.False })))) options = append(options, cel.Function("testV1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 21:31:27 UTC 2023 - 2.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/scope/WeakMojoExecutionListener.java
*/ package org.apache.maven.execution.scope; import org.apache.maven.execution.MojoExecutionEvent; import org.apache.maven.plugin.MojoExecutionException; /** * Extension point that allows build extensions observe and possibly veto mojo executions. * <p> * Unlike {@link org.apache.maven.execution.MojoExecutionListener}, this extension point does not
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 1.7K bytes - Viewed (0) -
src/runtime/tracecpu.go
} // Once we close the profbuf, we'll be in one of two situations: // - The logger goroutine has already exited because it observed // that the trace is disabled. // - The logger goroutine is asleep. // // Wake the goroutine so it can observe that their the buffer is // closed an exit. trace.cpuLogWrite[0].Store(nil) trace.cpuLogWrite[1].Store(nil) trace.cpuLogRead[0].close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/metrics.go
code := "500" if err == nil { code = "200" } else if se, ok := err.(*apierrors.StatusError); ok && se.Status().Code != 0 { code = strconv.Itoa(int(se.Status().Code)) } syncLatency.WithLabelValues(code).Observe(time.Since(start).Seconds()) syncCounter.WithLabelValues(code).Inc() } var once sync.Once func registerMetrics() { once.Do(func() { legacyregistry.MustRegister(syncCounter)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 16 12:05:32 UTC 2021 - 2K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/common/utils.cc
float_type_observed = true; } else if (IsQI8Type(input_type)) { int8_type_observed = true; } else if (IsQUI8Type(input_type)) { uint8_type_observed = true; } } // We should not observe both uint8 & int8. if (int8_type_observed && uint8_type_observed) return UNKNOWN; if (float_type_observed) { if (int8_type_observed || uint8_type_observed) { return HYBRID; } else {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 06 05:37:07 UTC 2024 - 2.3K bytes - Viewed (0)