metrics

Documentation

Index

• Constants
• func Duration(start time.Time) time.Duration
• func DurationInMicroseconds(duration time.Duration) float64
• func DurationInMilliseconds(duration time.Duration) float64
• func DurationInSeconds(duration time.Duration) float64
• func RegisterJobRetries(jobID string)
• func RegisterPreemptionAttempts()
• func UpdateActionDuration(actionName string, duration time.Duration)
• func UpdateE2eDuration(duration time.Duration)
• func UpdatePluginDuration(pluginName, OnSessionStatus string, duration time.Duration)
• func UpdatePodScheduleStatus(label string, count int)
• func UpdatePreemptionVictimsCount(victimsCount int)
• func UpdateTaskScheduleDuration(duration time.Duration)
• func UpdateUnscheduleJobCount(jobCount int)
• func UpdateUnscheduleTaskCount(jobID string, taskCount int)

Constants

const (
	// KubeBatchNamespace - namespace in prometheus used by kube-batch
	KubeBatchNamespace = "kube_batch"

	// 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 DurationInMicroseconds

func DurationInMicroseconds(duration time.Duration) float64

DurationInMicroseconds gets the time in microseconds.

func DurationInMilliseconds

func DurationInMilliseconds(duration time.Duration) float64

DurationInMilliseconds gets the time in milliseconds.

func DurationInSeconds

func DurationInSeconds(duration time.Duration) float64

DurationInSeconds gets the time in seconds.

func RegisterJobRetries

func RegisterJobRetries(jobID string)

RegisterJobRetries total number of job retries.

func RegisterPreemptionAttempts

func RegisterPreemptionAttempts()

RegisterPreemptionAttempts records number of attempts for preemtion

func UpdateActionDuration

func UpdateActionDuration(actionName string, duration time.Duration)

UpdateActionDuration updates latency for every action

func UpdateE2eDuration

func UpdateE2eDuration(duration time.Duration)

UpdateE2eDuration updates entire end to end scheduling latency

func UpdatePluginDuration

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

UpdatePluginDuration updates latency for every plugin

func UpdatePodScheduleStatus

func UpdatePodScheduleStatus(label string, count int)

UpdatePodScheduleStatus update pod schedule decision, could be Success, Failure, Error

func UpdatePreemptionVictimsCount

func UpdatePreemptionVictimsCount(victimsCount int)

UpdatePreemptionVictimsCount updates count of preemption victims

func UpdateTaskScheduleDuration

func UpdateTaskScheduleDuration(duration time.Duration)

UpdateTaskScheduleDuration updates single task scheduling latency

func UpdateUnscheduleJobCount

func UpdateUnscheduleJobCount(jobCount int)

UpdateUnscheduleJobCount records total number of unscheduleable jobs

func UpdateUnscheduleTaskCount

func UpdateUnscheduleTaskCount(jobID string, taskCount int)

UpdateUnscheduleTaskCount records total number of unscheduleable tasks