metrics

Documentation

Index

• Constants
• func Duration(start time.Time) time.Duration
• func IncPodgroupScheduledByAction()
• func IncPodgroupsConsideredByAction()
• func IncScenarioFilteredByAction()
• func IncScenarioSimulatedByAction()
• func InitMetrics(namespace string)
• func RecordPodGroupEvictedPods(name, namespace, uid, nodepool, action string, count int)
• func RegisterPreemptionAttempts()
• func ResetQueueFairShare()
• func ResetQueueUsage()
• func SetCurrentAction(action string)
• func UpdateActionDuration(actionName string, duration time.Duration)
• func UpdateCloseSessionDuration(startTime time.Time)
• func UpdateE2eDuration(startTime time.Time)
• func UpdateOpenSessionDuration(startTime time.Time)
• func UpdatePluginDuration(pluginName, OnSessionStatus string, duration time.Duration)
• func UpdateQueueFairShare(queueName string, cpu, memory, gpu float64)
• func UpdateQueueUsage(queueName string, cpu, memory, gpu float64)
• func UpdateTaskBindDuration(startTime time.Time)
• func UpdateTaskScheduleDuration(duration time.Duration)
• func UpdateUsageQueryLatency(latency time.Duration)

Constants

const (
	// OnSessionOpen label
	OnSessionOpen = "OnSessionOpen"

	// OnSessionClose label
	OnSessionClose = "OnSessionClose"
)

Functions

func Duration

func Duration(start time.Time) time.Duration

Duration get the time since specified start

func IncPodgroupScheduledByAction

func IncPodgroupScheduledByAction()

func IncPodgroupsConsideredByAction

func IncPodgroupsConsideredByAction()

func IncScenarioFilteredByAction

func IncScenarioFilteredByAction()

func IncScenarioSimulatedByAction

func IncScenarioSimulatedByAction()

func InitMetrics

func InitMetrics(namespace string)

func RecordPodGroupEvictedPods

func RecordPodGroupEvictedPods(name, namespace, uid, nodepool, action string, count int)

RecordPodGroupEvictedPods records the number of pods evicted for a pod group

func RegisterPreemptionAttempts

func RegisterPreemptionAttempts()

RegisterPreemptionAttempts records number of attempts for preemption

func ResetQueueFairShare

func ResetQueueFairShare()

func ResetQueueUsage

func ResetQueueUsage()

func SetCurrentAction

func SetCurrentAction(action string)

func UpdateActionDuration

func UpdateActionDuration(actionName string, duration time.Duration)

UpdateActionDuration updates latency for every action

func UpdateCloseSessionDuration

func UpdateCloseSessionDuration(startTime time.Time)

UpdateCloseSessionDuration updates latency for close session, including all plugins

func UpdateE2eDuration

func UpdateE2eDuration(startTime time.Time)

UpdateE2eDuration updates entire end to end scheduling latency

func UpdateOpenSessionDuration

func UpdateOpenSessionDuration(startTime time.Time)

UpdateOpenSessionDuration updates latency for open session, including all plugins

func UpdatePluginDuration

func UpdatePluginDuration(pluginName, OnSessionStatus string, duration time.Duration)

UpdatePluginDuration updates latency for every plugin

func UpdateQueueFairShare

func UpdateQueueFairShare(queueName string, cpu, memory, gpu float64)

UpdateQueueFairShare updates fair share of queue for a resource

func UpdateQueueUsage

func UpdateQueueUsage(queueName string, cpu, memory, gpu float64)

UpdateQueueUsage updates usage of queue for a resource

func UpdateTaskBindDuration

func UpdateTaskBindDuration(startTime time.Time)

UpdateTaskBindDuration updates single task bind latency, including bind request creation

func UpdateTaskScheduleDuration

func UpdateTaskScheduleDuration(duration time.Duration)

UpdateTaskScheduleDuration updates single task scheduling latency

func UpdateUsageQueryLatency

func UpdateUsageQueryLatency(latency time.Duration)