package metrics

import "k8s.io/apiserver/pkg/util/flowcontrol/metrics"

Index ¶

• func AddReject(priorityLevel string, reason string)
• func ObserveExecutionDuration(priorityLevel, flowSchema string, executionTime time.Duration)
• func ObserveQueueLength(priorityLevel string, length int)
• func ObserveWaitingDuration(priorityLevel, flowSchema, execute string, waitTime time.Duration)
• func UpdateFlowControlRequestsExecuting(priorityLevel string, executing int)
• func UpdateFlowControlRequestsInQueue(priorityLevel string, inqueue int)
• func UpdateSharedConcurrencyLimit(priorityLevel string, limit int)

Functions ¶

func AddReject ¶

func AddReject(priorityLevel string, reason string)

AddReject increments the # of rejected requests for flow control

func ObserveExecutionDuration ¶

func ObserveExecutionDuration(priorityLevel, flowSchema string, executionTime time.Duration)

ObserveExecutionDuration observes the execution duration for flow control

func ObserveQueueLength ¶

func ObserveQueueLength(priorityLevel string, length int)

ObserveQueueLength observes the queue length for flow control

func ObserveWaitingDuration ¶

func ObserveWaitingDuration(priorityLevel, flowSchema, execute string, waitTime time.Duration)

ObserveWaitingDuration observes the queue length for flow control

func UpdateFlowControlRequestsExecuting ¶

func UpdateFlowControlRequestsExecuting(priorityLevel string, executing int)

UpdateFlowControlRequestsExecuting updates the value for the # of requests executing in flow control

func UpdateFlowControlRequestsInQueue ¶

func UpdateFlowControlRequestsInQueue(priorityLevel string, inqueue int)

UpdateFlowControlRequestsInQueue updates the value for the # of requests in the specified queues in flow control

func UpdateSharedConcurrencyLimit ¶

func UpdateSharedConcurrencyLimit(priorityLevel string, limit int)

UpdateSharedConcurrencyLimit updates the value for the concurrency limit in flow control

Source Files ¶

metrics.go