Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 582 for observ (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top