metrics

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2022 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)
	// 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)
	// 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) 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)

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) 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.