metrics

Documentation

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