metrics

Documentation

Index

• Constants
• Variables
• func CountRequests(err error, estimatingType string)
• func UpdateEstimatingAlgorithmLatency(err error, estimatingType, estimatingStep string, startTime time.Time)

Constants

const (
	// EstimatingTypeMaxAvailableReplicas - label of estimating type
	EstimatingTypeMaxAvailableReplicas = "MaxAvailableReplicas"
	// EstimatingTypeGetUnschedulableReplicas - label of estimating type
	EstimatingTypeGetUnschedulableReplicas = "GetUnschedulableReplicas"
)

const (
	// EstimatingStepListNodesByNodeClaim - label of estimating step
	EstimatingStepListNodesByNodeClaim = "ListNodesByNodeClaim"
	// EstimatingStepMaxAvailableReplicas - label of estimating step
	EstimatingStepMaxAvailableReplicas = "MaxAvailableReplicas"
	// EstimatingStepGetObjectFromCache - label of estimating step
	EstimatingStepGetObjectFromCache = "GetObjectFromCache"
	// EstimatingStepGetUnschedulablePodsOfWorkload - label of estimating step
	EstimatingStepGetUnschedulablePodsOfWorkload = "GetWorkloadUnschedulablePods"
	// EstimatingStepTotal - label of estimating step, total step
	EstimatingStepTotal = "Total"
)

const SchedulerEstimatorSubsystem = "karmada_scheduler_estimator"

SchedulerEstimatorSubsystem - subsystem name used by scheduler estimator

Variables

var (

	// FrameworkExtensionPointDuration is the metrics which indicates the latency for running all plugins of a specific extension point.
	FrameworkExtensionPointDuration = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Subsystem: SchedulerEstimatorSubsystem,
			Name:      "estimating_plugin_extension_point_duration_seconds",
			Help:      "Latency for running all plugins of a specific extension point.",

			Buckets: prometheus.ExponentialBuckets(0.0001, 2, 12),
		},
		[]string{"estimating_plugin_extension_point"})

	// PluginExecutionDuration is the metrics which indicates the duration for running a plugin at a specific extension point.
	PluginExecutionDuration = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Subsystem: SchedulerEstimatorSubsystem,
			Name:      "estimating_plugin_execution_duration_seconds",
			Help:      "Duration for running a plugin at a specific extension point.",

			Buckets: prometheus.ExponentialBuckets(0.00001, 1.5, 20),
		},
		[]string{"estimating_plugin", "estimating_plugin_extension_point"})
)

Functions

func CountRequests

func CountRequests(err error, estimatingType string)

CountRequests total number of scheduler estimator requests

func UpdateEstimatingAlgorithmLatency

func UpdateEstimatingAlgorithmLatency(err error, estimatingType, estimatingStep string, startTime time.Time)

UpdateEstimatingAlgorithmLatency updates latency for every step