metrics

package
v0.0.0-...-ba58310 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: Apache-2.0 Imports: 13 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 (
	AppNew        = "new"
	AppAccepted   = "accepted"
	AppRunning    = "running"
	AppFailing    = "failing"
	AppFailed     = "failed"
	AppRejected   = "rejected"
	AppResuming   = "resuming"
	AppCompleting = "completing"
	AppCompleted  = "completed"
	AppExpired    = "expired"

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

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 

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

func GetEventMetrics 

func GetEventMetrics() *EventMetrics

func (*EventMetrics) AddEventsCollected 

func (em *EventMetrics) AddEventsCollected(collectedEvents int)

func (*EventMetrics) IncEventsChanneled 

func (em *EventMetrics) IncEventsChanneled()

func (*EventMetrics) IncEventsCreated 

func (em *EventMetrics) IncEventsCreated()

func (*EventMetrics) IncEventsNotChanneled 

func (em *EventMetrics) IncEventsNotChanneled()

func (*EventMetrics) IncEventsNotStored 

func (em *EventMetrics) IncEventsNotStored()

func (*EventMetrics) IncEventsProcessed 

func (em *EventMetrics) IncEventsProcessed()

func (*EventMetrics) IncEventsStored 

func (em *EventMetrics) IncEventsStored()

func (*EventMetrics) Reset 

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 

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 

func (m *QueueMetrics) AddReleasedContainers(value int)

func (*QueueMetrics) DecQueueApplicationsAccepted 

func (m *QueueMetrics) DecQueueApplicationsAccepted()

func (*QueueMetrics) DecQueueApplicationsCompleting 

func (m *QueueMetrics) DecQueueApplicationsCompleting()

func (*QueueMetrics) DecQueueApplicationsFailing 

func (m *QueueMetrics) DecQueueApplicationsFailing()

func (*QueueMetrics) DecQueueApplicationsNew 

func (m *QueueMetrics) DecQueueApplicationsNew()

func (*QueueMetrics) DecQueueApplicationsResuming 

func (m *QueueMetrics) DecQueueApplicationsResuming()

func (*QueueMetrics) DecQueueApplicationsRunning 

func (m *QueueMetrics) DecQueueApplicationsRunning()

func (*QueueMetrics) GetQueueApplicationsAccepted 

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

func (*QueueMetrics) GetQueueApplicationsCompleted 

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

func (*QueueMetrics) GetQueueApplicationsCompleting 

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

func (*QueueMetrics) GetQueueApplicationsFailed 

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

func (*QueueMetrics) GetQueueApplicationsFailing 

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

func (*QueueMetrics) GetQueueApplicationsNew 

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

func (*QueueMetrics) GetQueueApplicationsRejected 

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

func (*QueueMetrics) GetQueueApplicationsResuming 

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

func (*QueueMetrics) GetQueueApplicationsRunning 

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

func (m *QueueMetrics) IncQueueApplicationsCompleting()

func (*QueueMetrics) IncQueueApplicationsFailed 

func (m *QueueMetrics) IncQueueApplicationsFailed()

func (*QueueMetrics) IncQueueApplicationsFailing 

func (m *QueueMetrics) IncQueueApplicationsFailing()

func (*QueueMetrics) IncQueueApplicationsNew 

func (m *QueueMetrics) IncQueueApplicationsNew()

func (*QueueMetrics) IncQueueApplicationsRejected 

func (m *QueueMetrics) IncQueueApplicationsRejected()

func (*QueueMetrics) IncQueueApplicationsResuming 

func (m *QueueMetrics) IncQueueApplicationsResuming()

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

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

func (*QueueMetrics) SetQueuePreemptingResourceMetrics 

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

func (*QueueMetrics) UpdateQueueResourceMetrics 

func (m *QueueMetrics) UpdateQueueResourceMetrics(state string, newResources map[string]resources.Quantity)

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

func (m *SchedulerMetrics) DecActiveNodes()

func (*SchedulerMetrics) DecDrainingNodes 

func (m *SchedulerMetrics) DecDrainingNodes()

func (*SchedulerMetrics) DecFailedNodes 

func (m *SchedulerMetrics) DecFailedNodes()

func (*SchedulerMetrics) DecTotalApplicationsCompleting 

func (m *SchedulerMetrics) DecTotalApplicationsCompleting()

func (*SchedulerMetrics) DecTotalApplicationsFailing 

func (m *SchedulerMetrics) DecTotalApplicationsFailing()

func (*SchedulerMetrics) DecTotalApplicationsResuming 

func (m *SchedulerMetrics) DecTotalApplicationsResuming()

func (*SchedulerMetrics) DecTotalApplicationsRunning 

func (m *SchedulerMetrics) DecTotalApplicationsRunning()

func (*SchedulerMetrics) GetDrainingNodes 

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

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

func (*SchedulerMetrics) GetTotalApplicationsCompleted 

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

func (*SchedulerMetrics) GetTotalApplicationsNew 

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

func (*SchedulerMetrics) GetTotalApplicationsRejected 

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

func (*SchedulerMetrics) GetTotalApplicationsResuming 

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

func (*SchedulerMetrics) GetTotalApplicationsRunning 

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

func (m *SchedulerMetrics) IncTotalApplicationsCompleting()

func (*SchedulerMetrics) IncTotalApplicationsFailed 

func (m *SchedulerMetrics) IncTotalApplicationsFailed()

func (*SchedulerMetrics) IncTotalApplicationsFailing 

func (m *SchedulerMetrics) IncTotalApplicationsFailing()

func (*SchedulerMetrics) IncTotalApplicationsNew 

func (m *SchedulerMetrics) IncTotalApplicationsNew()

func (*SchedulerMetrics) IncTotalApplicationsRejected 

func (m *SchedulerMetrics) IncTotalApplicationsRejected()

func (*SchedulerMetrics) IncTotalApplicationsResuming 

func (m *SchedulerMetrics) IncTotalApplicationsResuming()

func (*SchedulerMetrics) IncTotalApplicationsRunning 

func (m *SchedulerMetrics) IncTotalApplicationsRunning()

func (*SchedulerMetrics) IncTotalDecommissionedNodes 

func (m *SchedulerMetrics) IncTotalDecommissionedNodes()

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 

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)

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.