metrics

Documentation

Index

• func AddDispatch(priorityLevel, flowSchema string)
• func AddReject(priorityLevel, flowSchema, reason string)
• func AddRequestsExecuting(priorityLevel, flowSchema string, delta int)
• func AddRequestsInQueues(priorityLevel, flowSchema string, delta int)
• func GatherAndCompare(expected string, metricNames ...string) error
• func ObserveExecutionDuration(priorityLevel, flowSchema string, executionTime time.Duration)
• func ObserveQueueLength(priorityLevel, flowSchema string, length int)
• func ObserveWaitingDuration(priorityLevel, flowSchema, execute string, waitTime time.Duration)
• func Register()
• func Reset()
• func UpdateSharedConcurrencyLimit(priorityLevel string, limit int)

Functions

func AddDispatch

func AddDispatch(priorityLevel, flowSchema string)

AddDispatch increments the # of dispatched requests for flow control

func AddReject

func AddReject(priorityLevel, flowSchema, reason string)

AddReject increments the # of rejected requests for flow control

func AddRequestsExecuting

func AddRequestsExecuting(priorityLevel, flowSchema string, delta int)

AddRequestsExecuting adds the given delta to the gauge of executing requests of the given flowSchema and priorityLevel

func AddRequestsInQueues

func AddRequestsInQueues(priorityLevel, flowSchema string, delta int)

AddRequestsInQueues adds the given delta to the gauge of the # of requests in the queues of the specified flowSchema and priorityLevel

func GatherAndCompare

func GatherAndCompare(expected string, metricNames ...string) error

GatherAndCompare the given metrics with the given Prometheus syntax expected value

func ObserveExecutionDuration

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

ObserveExecutionDuration observes the execution duration for flow control

func ObserveQueueLength

func ObserveQueueLength(priorityLevel, flowSchema 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 Register

func Register()

Register all metrics.

func Reset

func Reset()

Reset all metrics to zero

func UpdateSharedConcurrencyLimit

func UpdateSharedConcurrencyLimit(priorityLevel string, limit int)

UpdateSharedConcurrencyLimit updates the value for the concurrency limit in flow control