metrics

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2024 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 (
	AppAccepted  = "accepted"
	AppRunning   = "running"
	AppFailed    = "failed"
	AppRejected  = "rejected"
	AppCompleted = "completed"

	ContainerReleased  = "released"
	ContainerAllocated = "allocated"
	ContainerRejected  = "rejected"

	QueueGuaranteed = "guaranteed"
	QueueMax        = "max"
	QueuePending    = "pending"
	QueuePreempting = "preempting"
)
View Source 
const (
	MemStatsLabel = "MemStats"
	PauseNsLabel  = "PauseNs"
	PauseEndLabel = "PauseEnd"
	GenericLabel  = "Generic"
	Runtime       = "runtime"
)
View Source 
const (
	SchedulingError = "error"

	SortingApp   = "app"
	SortingQueue = "queue"

	NodeActive         = "active"
	NodeDraining       = "draining"
	NodeDecommissioned = "decommissioned"
	NodeUnhealthy      = "unhealthy"
)

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 EventMetrics added in v1.5.0 

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

func GetEventMetrics 

func GetEventMetrics() *EventMetrics

func (*EventMetrics) AddEventsCollected added in v1.5.0 

func (em *EventMetrics) AddEventsCollected(collectedEvents int)

func (*EventMetrics) IncEventsChanneled added in v1.5.0 

func (em *EventMetrics) IncEventsChanneled()

func (*EventMetrics) IncEventsCreated added in v1.5.0 

func (em *EventMetrics) IncEventsCreated()

func (*EventMetrics) IncEventsNotChanneled added in v1.5.0 

func (em *EventMetrics) IncEventsNotChanneled()

func (*EventMetrics) IncEventsNotStored added in v1.5.0 

func (em *EventMetrics) IncEventsNotStored()

func (*EventMetrics) IncEventsProcessed added in v1.5.0 

func (em *EventMetrics) IncEventsProcessed()

func (*EventMetrics) IncEventsStored added in v1.5.0 

func (em *EventMetrics) IncEventsStored()

func (*EventMetrics) Reset added in v1.5.0 

func (em *EventMetrics) Reset()

Reset all metrics that implement the Set functionality. Should only be used in tests

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 InternalMetricsCollector added in v1.5.0 

type InternalMetricsCollector interface {
	Stop()
}

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 {
	// contains filtered or unexported fields
}

QueueMetrics to declare queue metrics

func GetQueueMetrics 

func GetQueueMetrics(name string) *QueueMetrics

func InitQueueMetrics 

func InitQueueMetrics(name string) *QueueMetrics

InitQueueMetrics to initialize queue metrics

func (*QueueMetrics) AddReleasedContainers added in v1.4.0 

func (m *QueueMetrics) AddReleasedContainers(value int)

func (*QueueMetrics) DecQueueApplicationsRunning 

func (m *QueueMetrics) DecQueueApplicationsRunning()

func (*QueueMetrics) GetQueueApplicationsAccepted added in v1.4.0 

func (m *QueueMetrics) GetQueueApplicationsAccepted() (int, error)

func (*QueueMetrics) GetQueueApplicationsCompleted added in v1.4.0 

func (m *QueueMetrics) GetQueueApplicationsCompleted() (int, error)

func (*QueueMetrics) GetQueueApplicationsFailed added in v1.4.0 

func (m *QueueMetrics) GetQueueApplicationsFailed() (int, error)

func (*QueueMetrics) GetQueueApplicationsRejected added in v1.4.0 

func (m *QueueMetrics) GetQueueApplicationsRejected() (int, error)

func (*QueueMetrics) GetQueueApplicationsRunning added in v1.4.0 

func (m *QueueMetrics) GetQueueApplicationsRunning() (int, error)

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 GetRuntimeMetrics 

func GetRuntimeMetrics() *RuntimeMetrics

func (*RuntimeMetrics) Collect 

func (a *RuntimeMetrics) Collect()

func (*RuntimeMetrics) Reset 

func (a *RuntimeMetrics) Reset()

Reset all metrics that implement the Reset functionality. should only be used in tests

type SchedulerMetrics 

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

SchedulerMetrics to declare scheduler metrics

func GetSchedulerMetrics 

func GetSchedulerMetrics() *SchedulerMetrics

func InitSchedulerMetrics 

func InitSchedulerMetrics() *SchedulerMetrics

InitSchedulerMetrics to initialize scheduler metrics

func (*SchedulerMetrics) AddAllocatedContainers 

func (m *SchedulerMetrics) AddAllocatedContainers(value int)

func (*SchedulerMetrics) AddRejectedContainers 

func (m *SchedulerMetrics) AddRejectedContainers(value int)

func (*SchedulerMetrics) AddReleasedContainers 

func (m *SchedulerMetrics) AddReleasedContainers(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) DecActiveNodes 

func (m *SchedulerMetrics) DecActiveNodes()

func (*SchedulerMetrics) DecDrainingNodes 

func (m *SchedulerMetrics) DecDrainingNodes()

func (*SchedulerMetrics) DecFailedNodes 

func (m *SchedulerMetrics) DecFailedNodes()

func (*SchedulerMetrics) DecTotalApplicationsRunning 

func (m *SchedulerMetrics) DecTotalApplicationsRunning()

func (*SchedulerMetrics) DecUnhealthyNodes 

func (m *SchedulerMetrics) DecUnhealthyNodes()

func (*SchedulerMetrics) GetDrainingNodes added in v1.4.0 

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

func (*SchedulerMetrics) GetFailedNodes 

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

func (*SchedulerMetrics) GetSchedulingErrors 

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

func (*SchedulerMetrics) GetTotalApplicationsCompleted added in v1.4.0 

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

func (*SchedulerMetrics) GetTotalApplicationsRejected added in v1.4.0 

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

func (*SchedulerMetrics) GetTotalApplicationsRunning added in v1.4.0 

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

func (*SchedulerMetrics) IncActiveNodes 

func (m *SchedulerMetrics) IncActiveNodes()

func (*SchedulerMetrics) IncDrainingNodes 

func (m *SchedulerMetrics) IncDrainingNodes()

func (*SchedulerMetrics) IncFailedNodes 

func (m *SchedulerMetrics) IncFailedNodes()

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

Reset all metrics that implement the Reset functionality. should only be used in tests

func (*SchedulerMetrics) SetNodeResourceUsage 

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

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.