Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ObserveWebhook (0.25 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go

    					admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "validating", 0)
    				}
    			} else {
    				admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "validating", 200)
    				return
    			}
    
    			if callErr, ok := err.(*webhookutil.ErrCallingWebhook); ok {
    				if ignoreClientCallFailures {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 20:24:12 UTC 2023
    - 13K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    				admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "admit", 0)
    			}
    		} else {
    			admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "admit", 200)
    		}
    		if changed {
    			// Patch had changed the object. Prepare to reinvoke all previous webhooks that are eligible for re-invocation.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics_test.go

    }
    
    func TestObserveWebhook(t *testing.T) {
    	defer Metrics.reset()
    	defer legacyregistry.Reset()
    	Metrics.ObserveWebhook(context.TODO(), "x", 2*time.Second, false, attr, stepAdmit, 200)
    	Metrics.ObserveWebhook(context.TODO(), "x", 2*time.Second, true, attr, stepValidate, 654)
    	wantLabelsCounterAdmit := map[string]string{
    		"name":      "x",
    		"operation": string(admission.Create),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:01:37 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics.go

    	m.controller.observe(ctx, elapsed, append(extraLabels, stepType, string(attr.GetOperation()), strconv.FormatBool(rejected))...)
    }
    
    // ObserveWebhook records admission related metrics for a admission webhook.
    func (m *AdmissionMetrics) ObserveWebhook(ctx context.Context, name string, elapsed time.Duration, rejected bool, attr admission.Attributes, stepType string, code int) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:01:40 UTC 2023
    - 15.5K bytes
    - Viewed (0)
Back to top