metrics

package
v1.3.0-1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 31, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Namespace for all metrics inside the scheduler
	Namespace = "yunikorn"
	// SchedulerSubsystem - subsystem name used by scheduler
	SchedulerSubsystem = "scheduler"
	// EventSubsystem - subsystem name used by event cache
	EventSubsystem = "event"
	// MetricNameInvalidByteReplacement byte used to replace invalid bytes in prometheus metric names
	MetricNameInvalidByteReplacement = '_'
)
View Source 
const (
	MemStatsLabel = "MemStats"
	PauseNsLabel  = "PauseNs"
	PauseEndLabel = "PauseEnd"
	GenericLabel  = "Generic"
	Runtime       = "runtime"
)

Variables

This section is empty.

Functions

func NewInternalMetricsCollector 

func NewInternalMetricsCollector(hcInfo *history.InternalMetricsHistory) *internalMetricsCollector

func Reset 

func Reset()

func SinceInSeconds 

func SinceInSeconds(start time.Time) float64

Types

type CoreEventMetrics 

type CoreEventMetrics interface {
	IncEventsCreated()
	IncEventsChanneled()
	IncEventsNotChanneled()
	IncEventsProcessed()
	IncEventsStored()
	IncEventsNotStored()
	AddEventsCollected(collectedEvents int)
	// Reset all metrics that implement the Set functionality.
	// Should only be used in tests
	Reset()
}

func GetEventMetrics 

func GetEventMetrics() CoreEventMetrics

type CoreQueueMetrics 

type CoreQueueMetrics interface {
	IncQueueApplicationsAccepted()
	IncQueueApplicationsRejected()
	IncQueueApplicationsRunning()
	DecQueueApplicationsRunning()
	IncQueueApplicationsFailed()
	IncQueueApplicationsCompleted()
	IncAllocatedContainer()
	IncReleasedContainer()
	SetQueueGuaranteedResourceMetrics(resourceName string, value float64)
	SetQueueMaxResourceMetrics(resourceName string, value float64)
	SetQueueAllocatedResourceMetrics(resourceName string, value float64)
	AddQueueAllocatedResourceMetrics(resourceName string, value float64)
	SetQueuePendingResourceMetrics(resourceName string, value float64)
	AddQueuePendingResourceMetrics(resourceName string, value float64)
	SetQueuePreemptingResourceMetrics(resourceName string, value float64)
	AddQueuePreemptingResourceMetrics(resourceName string, value float64)
	// Reset all metrics that implement the Reset functionality.
	// should only be used in tests
	Reset()
}

func GetQueueMetrics 

func GetQueueMetrics(name string) CoreQueueMetrics

func InitQueueMetrics 

func InitQueueMetrics(name string) CoreQueueMetrics

InitQueueMetrics to initialize queue metrics

type CoreSchedulerMetrics 

type CoreSchedulerMetrics interface {
	// Metrics Ops related to ScheduledAllocationSuccesses
	IncAllocatedContainer()
	AddAllocatedContainers(value int)

	// Metrics Ops related to ScheduledAllocationFailures
	IncRejectedContainer()
	AddRejectedContainers(value int)

	// Metrics Ops related to ScheduledAllocationErrors
	IncSchedulingError()
	AddSchedulingErrors(value int)
	GetSchedulingErrors() (int, error)

	// Metrics Ops related to released allocations
	IncReleasedContainer()
	AddReleasedContainers(value int)

	// Metrics Ops related to totalApplicationsAccepted
	IncTotalApplicationsAccepted()
	AddTotalApplicationsAccepted(value int)

	// Metrics Ops related to TotalApplicationsRejected
	IncTotalApplicationsRejected()
	AddTotalApplicationsRejected(value int)

	// Metrics Ops related to TotalApplicationsRunning
	IncTotalApplicationsRunning()
	AddTotalApplicationsRunning(value int)
	DecTotalApplicationsRunning()
	SubTotalApplicationsRunning(value int)
	SetTotalApplicationsRunning(value int)

	// Metrics Ops related to TotalApplicationsFailed
	IncTotalApplicationsFailed()

	// Metrics Ops related to TotalApplicationsCompleted
	IncTotalApplicationsCompleted()
	AddTotalApplicationsCompleted(value int)
	DecTotalApplicationsCompleted()
	SubTotalApplicationsCompleted(value int)
	SetTotalApplicationsCompleted(value int)

	// Metrics Ops related to ActiveNodes
	IncActiveNodes()
	AddActiveNodes(value int)
	DecActiveNodes()
	SubActiveNodes(value int)
	SetActiveNodes(value int)
	IncDrainingNodes()
	DecDrainingNodes()
	IncUnhealthyNodes()
	DecUnhealthyNodes()
	IncTotalDecommissionedNodes()

	// Metrics Ops related to failedNodes
	IncFailedNodes()
	AddFailedNodes(value int)
	DecFailedNodes()
	SubFailedNodes(value int)
	SetFailedNodes(value int)
	SetNodeResourceUsage(resourceName string, rangeIdx int, value float64)
	GetFailedNodes() (int, error)

	// Metrics Ops related to latency change
	ObserveSchedulingLatency(start time.Time)
	ObserveNodeSortingLatency(start time.Time)
	ObserveAppSortingLatency(start time.Time)
	ObserveQueueSortingLatency(start time.Time)
	ObserveTryNodeLatency(start time.Time)
	ObserveTryPreemptionLatency(start time.Time)
	// Reset all metrics that implement the Reset functionality.
	// should only be used in tests
	Reset()
	// contains filtered or unexported methods
}

Declare all core metrics ops in this interface

func GetSchedulerMetrics 

func GetSchedulerMetrics() CoreSchedulerMetrics

type GenericMetrics 

type GenericMetrics struct {
	// contains filtered or unexported fields
}

func (*GenericMetrics) Collect 

func (gm *GenericMetrics) Collect()

func (*GenericMetrics) Reset 

func (gm *GenericMetrics) Reset()

type GoRuntimeMetrics 

type GoRuntimeMetrics interface {
	Collect()
	// Reset all metrics that implement the Reset functionality.
	// should only be used in tests
	Reset()
}

func GetRuntimeMetrics 

func GetRuntimeMetrics() GoRuntimeMetrics

type MStatsMetrics 

type MStatsMetrics struct {
	// contains filtered or unexported fields
}

func (*MStatsMetrics) Collect 

func (ms *MStatsMetrics) Collect()

func (*MStatsMetrics) Reset 

func (ms *MStatsMetrics) Reset()

type Metrics 

type Metrics struct {
	// contains filtered or unexported fields
}

type QueueMetrics 

type QueueMetrics struct {
	ResourceMetrics *prometheus.GaugeVec
	// contains filtered or unexported fields
}

QueueMetrics to declare queue metrics

func (*QueueMetrics) AddQueueAllocatedResourceMetrics 

func (m *QueueMetrics) AddQueueAllocatedResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) AddQueuePendingResourceMetrics 

func (m *QueueMetrics) AddQueuePendingResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) AddQueuePreemptingResourceMetrics added in v1.3.0 

func (m *QueueMetrics) AddQueuePreemptingResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) DecQueueApplicationsRunning 

func (m *QueueMetrics) DecQueueApplicationsRunning()

func (*QueueMetrics) IncAllocatedContainer 

func (m *QueueMetrics) IncAllocatedContainer()

func (*QueueMetrics) IncQueueApplicationsAccepted 

func (m *QueueMetrics) IncQueueApplicationsAccepted()

func (*QueueMetrics) IncQueueApplicationsCompleted 

func (m *QueueMetrics) IncQueueApplicationsCompleted()

func (*QueueMetrics) IncQueueApplicationsFailed 

func (m *QueueMetrics) IncQueueApplicationsFailed()

func (*QueueMetrics) IncQueueApplicationsRejected 

func (m *QueueMetrics) IncQueueApplicationsRejected()

func (*QueueMetrics) IncQueueApplicationsRunning 

func (m *QueueMetrics) IncQueueApplicationsRunning()

func (*QueueMetrics) IncReleasedContainer 

func (m *QueueMetrics) IncReleasedContainer()

func (*QueueMetrics) Reset 

func (m *QueueMetrics) Reset()

func (*QueueMetrics) SetQueueAllocatedResourceMetrics 

func (m *QueueMetrics) SetQueueAllocatedResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) SetQueueGuaranteedResourceMetrics 

func (m *QueueMetrics) SetQueueGuaranteedResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) SetQueueMaxResourceMetrics 

func (m *QueueMetrics) SetQueueMaxResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) SetQueuePendingResourceMetrics 

func (m *QueueMetrics) SetQueuePendingResourceMetrics(resourceName string, value float64)

func (*QueueMetrics) SetQueuePreemptingResourceMetrics added in v1.3.0 

func (m *QueueMetrics) SetQueuePreemptingResourceMetrics(resourceName string, value float64)

type RuntimeMetrics 

type RuntimeMetrics struct {
	*MStatsMetrics
	*GenericMetrics
}

func (*RuntimeMetrics) Collect 

func (a *RuntimeMetrics) Collect()

func (*RuntimeMetrics) Reset 

func (a *RuntimeMetrics) Reset()

type SchedulerMetrics 

type SchedulerMetrics struct {
	// contains filtered or unexported fields
}

SchedulerMetrics to declare scheduler metrics

func InitSchedulerMetrics 

func InitSchedulerMetrics() *SchedulerMetrics

InitSchedulerMetrics to initialize scheduler metrics

func (*SchedulerMetrics) AddActiveNodes 

func (m *SchedulerMetrics) AddActiveNodes(value int)

func (*SchedulerMetrics) AddAllocatedContainers 

func (m *SchedulerMetrics) AddAllocatedContainers(value int)

func (*SchedulerMetrics) AddFailedNodes 

func (m *SchedulerMetrics) AddFailedNodes(value int)

func (*SchedulerMetrics) AddRejectedContainers 

func (m *SchedulerMetrics) AddRejectedContainers(value int)

func (*SchedulerMetrics) AddReleasedContainers 

func (m *SchedulerMetrics) AddReleasedContainers(value int)

func (*SchedulerMetrics) AddSchedulingErrors 

func (m *SchedulerMetrics) AddSchedulingErrors(value int)

func (*SchedulerMetrics) AddTotalApplicationsAccepted 

func (m *SchedulerMetrics) AddTotalApplicationsAccepted(value int)

func (*SchedulerMetrics) AddTotalApplicationsCompleted 

func (m *SchedulerMetrics) AddTotalApplicationsCompleted(value int)

func (*SchedulerMetrics) AddTotalApplicationsRejected 

func (m *SchedulerMetrics) AddTotalApplicationsRejected(value int)

func (*SchedulerMetrics) AddTotalApplicationsRunning 

func (m *SchedulerMetrics) AddTotalApplicationsRunning(value int)

func (*SchedulerMetrics) DecActiveNodes 

func (m *SchedulerMetrics) DecActiveNodes()

func (*SchedulerMetrics) DecDrainingNodes 

func (m *SchedulerMetrics) DecDrainingNodes()

func (*SchedulerMetrics) DecFailedNodes 

func (m *SchedulerMetrics) DecFailedNodes()

func (*SchedulerMetrics) DecTotalApplicationsCompleted 

func (m *SchedulerMetrics) DecTotalApplicationsCompleted()

func (*SchedulerMetrics) DecTotalApplicationsRunning 

func (m *SchedulerMetrics) DecTotalApplicationsRunning()

func (*SchedulerMetrics) DecUnhealthyNodes 

func (m *SchedulerMetrics) DecUnhealthyNodes()

func (*SchedulerMetrics) GetFailedNodes 

func (m *SchedulerMetrics) GetFailedNodes() (int, error)

func (*SchedulerMetrics) GetSchedulingErrors 

func (m *SchedulerMetrics) GetSchedulingErrors() (int, error)

func (*SchedulerMetrics) IncActiveNodes 

func (m *SchedulerMetrics) IncActiveNodes()

func (*SchedulerMetrics) IncAllocatedContainer 

func (m *SchedulerMetrics) IncAllocatedContainer()

func (*SchedulerMetrics) IncDrainingNodes 

func (m *SchedulerMetrics) IncDrainingNodes()

func (*SchedulerMetrics) IncFailedNodes 

func (m *SchedulerMetrics) IncFailedNodes()

func (*SchedulerMetrics) IncRejectedContainer 

func (m *SchedulerMetrics) IncRejectedContainer()

func (*SchedulerMetrics) IncReleasedContainer 

func (m *SchedulerMetrics) IncReleasedContainer()

func (*SchedulerMetrics) IncSchedulingError 

func (m *SchedulerMetrics) IncSchedulingError()

func (*SchedulerMetrics) IncTotalApplicationsAccepted 

func (m *SchedulerMetrics) IncTotalApplicationsAccepted()

func (*SchedulerMetrics) IncTotalApplicationsCompleted 

func (m *SchedulerMetrics) IncTotalApplicationsCompleted()

func (*SchedulerMetrics) IncTotalApplicationsFailed 

func (m *SchedulerMetrics) IncTotalApplicationsFailed()

func (*SchedulerMetrics) IncTotalApplicationsRejected 

func (m *SchedulerMetrics) IncTotalApplicationsRejected()

func (*SchedulerMetrics) IncTotalApplicationsRunning 

func (m *SchedulerMetrics) IncTotalApplicationsRunning()

func (*SchedulerMetrics) IncTotalDecommissionedNodes 

func (m *SchedulerMetrics) IncTotalDecommissionedNodes()

func (*SchedulerMetrics) IncUnhealthyNodes 

func (m *SchedulerMetrics) IncUnhealthyNodes()

func (*SchedulerMetrics) ObserveAppSortingLatency 

func (m *SchedulerMetrics) ObserveAppSortingLatency(start time.Time)

func (*SchedulerMetrics) ObserveNodeSortingLatency 

func (m *SchedulerMetrics) ObserveNodeSortingLatency(start time.Time)

func (*SchedulerMetrics) ObserveQueueSortingLatency 

func (m *SchedulerMetrics) ObserveQueueSortingLatency(start time.Time)

func (*SchedulerMetrics) ObserveSchedulingLatency 

func (m *SchedulerMetrics) ObserveSchedulingLatency(start time.Time)

func (*SchedulerMetrics) ObserveTryNodeLatency 

func (m *SchedulerMetrics) ObserveTryNodeLatency(start time.Time)

func (*SchedulerMetrics) ObserveTryPreemptionLatency added in v1.3.0 

func (m *SchedulerMetrics) ObserveTryPreemptionLatency(start time.Time)

func (*SchedulerMetrics) Reset 

func (m *SchedulerMetrics) Reset()

func (*SchedulerMetrics) SetActiveNodes 

func (m *SchedulerMetrics) SetActiveNodes(value int)

func (*SchedulerMetrics) SetFailedNodes 

func (m *SchedulerMetrics) SetFailedNodes(value int)

func (*SchedulerMetrics) SetNodeResourceUsage 

func (m *SchedulerMetrics) SetNodeResourceUsage(resourceName string, rangeIdx int, value float64)

func (*SchedulerMetrics) SetTotalApplicationsCompleted 

func (m *SchedulerMetrics) SetTotalApplicationsCompleted(value int)

func (*SchedulerMetrics) SetTotalApplicationsRunning 

func (m *SchedulerMetrics) SetTotalApplicationsRunning(value int)

func (*SchedulerMetrics) SubActiveNodes 

func (m *SchedulerMetrics) SubActiveNodes(value int)

func (*SchedulerMetrics) SubFailedNodes 

func (m *SchedulerMetrics) SubFailedNodes(value int)

func (*SchedulerMetrics) SubTotalApplicationsCompleted 

func (m *SchedulerMetrics) SubTotalApplicationsCompleted(value int)

func (*SchedulerMetrics) SubTotalApplicationsRunning 

func (m *SchedulerMetrics) SubTotalApplicationsRunning(value int)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.