Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ObserveWaitingDuration (0.12 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go

    	apiserverRequestQueueLength.WithContext(ctx).WithLabelValues(priorityLevel, flowSchema).Observe(float64(length))
    }
    
    // ObserveWaitingDuration observes the queue length for flow control
    func ObserveWaitingDuration(ctx context.Context, priorityLevel, flowSchema, execute string, waitTime time.Duration) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 19:40:05 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    	}
    	panicking = false
    }
    
    func observeQueueWaitTime(ctx context.Context, priorityLevelName, flowSchemaName, execute string, waitTime time.Duration) {
    	metrics.ObserveWaitingDuration(ctx, priorityLevelName, flowSchemaName, execute, waitTime)
    	endpointsrequest.TrackAPFQueueWaitLatency(ctx, waitTime)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
Back to top