metrics

Documentation

Index

• Constants
• func ConvertToUnix(t time.Time) float64
• func DeleteJobMetrics(jobName, queue, namespace string)
• func DeleteQueueMetrics(queueName string)
• 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 UpdateE2eSchedulingDurationByJob(jobName string, queue string, namespace string, duration time.Duration)
• func UpdateE2eSchedulingLastTimeByJob(jobName string, queue string, namespace string, t time.Time)
• func UpdateE2eSchedulingStartTimeByJob(jobName string, queue string, namespace string, t time.Time)
• func UpdateJobShare(jobNs, jobID string, share float64)
• func UpdateNamespaceShare(namespaceName string, share float64)
• func UpdateNamespaceWeight(namespaceName string, weight int64)
• func UpdateNamespaceWeightedShare(namespaceName string, weightedShare float64)
• func UpdatePluginDuration(pluginName, onSessionStatus string, duration time.Duration)
• func UpdatePodScheduleStatus(label string, count int)
• func UpdatePreemptionVictimsCount(victimsCount int)
• func UpdateQueueAllocated(queueName string, milliCPU, memory float64)
• func UpdateQueueDeserved(queueName string, milliCPU, memory float64)
• func UpdateQueueOverused(queueName string, overused bool)
• func UpdateQueuePodGroupInqueueCount(queueName string, count int32)
• func UpdateQueuePodGroupPendingCount(queueName string, count int32)
• func UpdateQueuePodGroupRunningCount(queueName string, count int32)
• func UpdateQueuePodGroupUnknownCount(queueName string, count int32)
• func UpdateQueueRequest(queueName string, milliCPU, memory float64)
• func UpdateQueueShare(queueName string, share float64)
• func UpdateQueueWeight(queueName string, weight int32)
• func UpdateTaskScheduleDuration(duration time.Duration)
• func UpdateUnscheduleJobCount(jobCount int)
• func UpdateUnscheduleTaskCount(jobID string, taskCount int)

Constants

const (
	// VolcanoNamespace - namespace in prometheus used by volcano
	VolcanoNamespace = "volcano"

	// OnSessionOpen label
	OnSessionOpen = "OnSessionOpen"

	// OnSessionClose label
	OnSessionClose = "OnSessionClose"
)

Functions

func ConvertToUnix

func ConvertToUnix(t time.Time) float64

ConvertToUnix convert the time to Unix time

func DeleteJobMetrics

func DeleteJobMetrics(jobName, queue, namespace string)

DeleteJobMetrics delete all metrics related to the job

func DeleteQueueMetrics

func DeleteQueueMetrics(queueName string)

DeleteQueueMetrics delete all metrics related to the queue

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 UpdateE2eSchedulingDurationByJob

func UpdateE2eSchedulingDurationByJob(jobName string, queue string, namespace string, duration time.Duration)

UpdateE2eSchedulingDurationByJob updates entire end to end scheduling duration

func UpdateE2eSchedulingLastTimeByJob

func UpdateE2eSchedulingLastTimeByJob(jobName string, queue string, namespace string, t time.Time)

UpdateE2eSchedulingLastTimeByJob updates the last time of scheduling

func UpdateE2eSchedulingStartTimeByJob

func UpdateE2eSchedulingStartTimeByJob(jobName string, queue string, namespace string, t time.Time)

UpdateE2eSchedulingStartTimeByJob updates the start time of scheduling

func UpdateJobShare

func UpdateJobShare(jobNs, jobID string, share float64)

UpdateJobShare records share for one job

func UpdateNamespaceShare

func UpdateNamespaceShare(namespaceName string, share float64)

UpdateNamespaceShare records share for one namespace

func UpdateNamespaceWeight

func UpdateNamespaceWeight(namespaceName string, weight int64)

UpdateNamespaceWeight records weight for one namespace

func UpdateNamespaceWeightedShare

func UpdateNamespaceWeightedShare(namespaceName string, weightedShare float64)

UpdateNamespaceWeightedShare records weighted share for one namespace

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 UpdateQueueAllocated

func UpdateQueueAllocated(queueName string, milliCPU, memory float64)

UpdateQueueAllocated records allocated resources for one queue

func UpdateQueueDeserved

func UpdateQueueDeserved(queueName string, milliCPU, memory float64)

UpdateQueueDeserved records deserved resources for one queue

func UpdateQueueOverused

func UpdateQueueOverused(queueName string, overused bool)

UpdateQueueOverused records if one queue is overused

func UpdateQueuePodGroupInqueueCount

func UpdateQueuePodGroupInqueueCount(queueName string, count int32)

UpdateQueuePodGroupInqueueCount records the number of Inqueue PodGroup in this queue

func UpdateQueuePodGroupPendingCount

func UpdateQueuePodGroupPendingCount(queueName string, count int32)

UpdateQueuePodGroupPendingCount records the number of Pending PodGroup in this queue

func UpdateQueuePodGroupRunningCount

func UpdateQueuePodGroupRunningCount(queueName string, count int32)

UpdateQueuePodGroupRunningCount records the number of Running PodGroup in this queue

func UpdateQueuePodGroupUnknownCount

func UpdateQueuePodGroupUnknownCount(queueName string, count int32)

UpdateQueuePodGroupUnknownCount records the number of Unknown PodGroup in this queue

func UpdateQueueRequest

func UpdateQueueRequest(queueName string, milliCPU, memory float64)

UpdateQueueRequest records request resources for one queue

func UpdateQueueShare

func UpdateQueueShare(queueName string, share float64)

UpdateQueueShare records share for one queue

func UpdateQueueWeight

func UpdateQueueWeight(queueName string, weight int32)

UpdateQueueWeight records weight for one queue

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