- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 582 for observ (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics.go
if m.latenciesSummary != nil { m.latenciesSummary.Reset() } } // Observe records an observed admission event to all metrics in the metricSet. func (m *metricSet) observe(ctx context.Context, elapsed time.Duration, labels ...string) { elapsedSeconds := elapsed.Seconds() m.latencies.WithContext(ctx).WithLabelValues(labels...).Observe(elapsedSeconds) if m.latenciesSummary != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:01:40 UTC 2023 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/metrics/metrics.go
m.policyCheck.WithContext(ctx).WithLabelValues(policy, binding, "allow", state).Inc() m.policyLatency.WithContext(ctx).WithLabelValues(policy, binding, "allow", state).Observe(elapsed.Seconds()) } // ObserveRejection observes a policy validation error that was at least one of the reasons for a deny.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 5.4K bytes - Viewed (0) -
src/internal/runtime/atomic/types_64bit.go
package atomic // LoadAcquire is a partially unsynchronized version // of Load that relaxes ordering constraints. Other threads // may observe operations that precede this operation to // occur after it, but no operation that occurs after it // on this thread can be observed to occur before it. // // WARNING: Use sparingly and with great care. // //go:nosplit func (u *Uint64) LoadAcquire() uint64 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.1K bytes - Viewed (0) -
pkg/controller/podautoscaler/monitor/monitor.go
} // ObserveReconciliationResult observes some metrics from a reconciliation result. func (r *monitor) ObserveReconciliationResult(action ActionLabel, err ErrorLabel, duration time.Duration) { reconciliationsTotal.WithLabelValues(string(action), string(err)).Inc() reconciliationsDuration.WithLabelValues(string(action), string(err)).Observe(duration.Seconds()) } // ObserveMetricComputationResult observes some metrics from a metric computation result.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 22:47:24 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/metrics/metrics_test.go
"apiserver_validating_admission_policy_check_total", "apiserver_validating_admission_policy_check_duration_seconds", } testCases := []struct { desc string want string observer metricsObserver }{ { desc: "observe policy admission", want: `
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 6.9K bytes - Viewed (0) -
doc/go_mem.html
<p> A read <i>r</i> of a memory location <i>x</i> holding a value that is not larger than a machine word must observe some write <i>w</i> such that <i>r</i> does not happen before <i>w</i> and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i> and <i>w'</i> happens before <i>r</i>. That is, each read must observe a value written by a preceding or concurrent write. </p> <p>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/monitoring/derived_gauge.go
} _, err := meter().Float64ObservableGauge(name, api.WithDescription(description), api.WithFloat64Callback(func(ctx context.Context, observer api.Float64Observer) error { dm.mu.RLock() defer dm.mu.RUnlock() for kv, compute := range dm.attrs { observer.Observe(compute(), api.WithAttributeSet(kv)) } return nil })) if err != nil { log.Fatalf("failed to create derived gauge: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker.go
"observedRunningTime", state.observedRunningTime, "watchObservedRunningTime", when) metrics.PodStartSLIDuration.WithLabelValues().Observe(podStartSLOduration) metrics.PodStartTotalDuration.WithLabelValues().Observe(podStartingDuration.Seconds()) state.metricRecorded = true // if is the first Pod with network track the start values
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/util/flag/flags_test.go
err = r.(error) } }() fs.Parse(strings.Split(tc.argc, " ")) }() if tc.expectErr && err == nil { t.Errorf("did not observe an expected error") continue } if !tc.expectErr && err != nil { t.Errorf("observed an unexpected error: %v", err) continue } if tc.expectVal != ip { t.Errorf("unexpected ip: expected %q, saw %q", tc.expectVal, ip) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 14 10:45:23 UTC 2021 - 8.8K bytes - Viewed (0) -
pkg/monitoring/gauge.go
g, err := meter().Float64ObservableGauge(o.name, api.WithFloat64Callback(func(ctx context.Context, observer api.Float64Observer) error { r.attributeSetsMutex.Lock() defer r.attributeSetsMutex.Unlock() for _, gv := range r.attributeSets { observer.Observe(gv.val, gv.opt...) } return nil }), api.WithDescription(o.description), api.WithUnit(string(o.unit))) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 2.9K bytes - Viewed (0)