metrics

package
v0.12.2 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// all metrics should be declared under this namespace
	Namespace = "yunikorn"
	// SchedulerSubsystem - subsystem name used by scheduler
	SchedulerSubsystem = "scheduler"
	// EventSubsystem - subsystem name used by event cache
	EventSubsystem = "event"
	// replacement of invalid byte for prometheus metric names
	MetricNameInvalidByteReplacement = '_'
)

Variables

This section is empty.

Functions

func NewInternalMetricsCollector 

func NewInternalMetricsCollector(hcInfo *history.InternalMetricsHistory) *internalMetricsCollector

func Reset 

func Reset()

To reset metrics

func SinceInSeconds 

func SinceInSeconds(start time.Time) float64

Types

type CoreEventMetrics added in v0.9.0 

type CoreEventMetrics interface {
	IncEventsCreated()
	IncEventsChanneled()
	IncEventsNotChanneled()
	IncEventsProcessed()
	IncEventsStored()
	IncEventsNotStored()
	AddEventsCollected(collectedEvents int)
}

func GetEventMetrics added in v0.9.0 

func GetEventMetrics() CoreEventMetrics

type CoreQueueMetrics 

type CoreQueueMetrics interface {
	IncApplicationsAccepted()
	IncApplicationsRejected()
	IncApplicationsCompleted()
	AddQueueUsedResourceMetrics(resourceName string, value float64)
	SetQueueUsedResourceMetrics(resourceName string, value float64)
}

func GetQueueMetrics 

func GetQueueMetrics(name string) CoreQueueMetrics

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

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

	//latency change
	ObserveSchedulingLatency(start time.Time)
	ObserveNodeSortingLatency(start time.Time)
	ObserveAppSortingLatency(start time.Time)
	ObserveQueueSortingLatency(start time.Time)
	ObserveTryNodeLatency(start time.Time)
	// contains filtered or unexported methods
}

Declare all core metrics ops in this interface

func GetSchedulerMetrics 

func GetSchedulerMetrics() CoreSchedulerMetrics

type Metrics 

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

type QueueMetrics 

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

func (*QueueMetrics) AddQueueUsedResourceMetrics 

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

func (*QueueMetrics) IncApplicationsAccepted 

func (m *QueueMetrics) IncApplicationsAccepted()

func (*QueueMetrics) IncApplicationsCompleted 

func (m *QueueMetrics) IncApplicationsCompleted()

func (*QueueMetrics) IncApplicationsRejected 

func (m *QueueMetrics) IncApplicationsRejected()

func (*QueueMetrics) SetQueueUsedResourceMetrics 

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

type SchedulerMetrics 

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

SchedulerMetrics to declare scheduler metrics

func InitSchedulerMetrics added in v0.10.0 

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 added in v0.12.0 

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

func (m *SchedulerMetrics) DecFailedNodes()

func (*SchedulerMetrics) DecTotalApplicationsCompleted 

func (m *SchedulerMetrics) DecTotalApplicationsCompleted()

func (*SchedulerMetrics) DecTotalApplicationsRunning 

func (m *SchedulerMetrics) DecTotalApplicationsRunning()

func (*SchedulerMetrics) GetFailedNodes added in v0.10.0 

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

func (*SchedulerMetrics) GetSchedulingErrors added in v0.10.0 

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

func (*SchedulerMetrics) IncActiveNodes 

func (m *SchedulerMetrics) IncActiveNodes()

func (*SchedulerMetrics) IncAllocatedContainer 

func (m *SchedulerMetrics) IncAllocatedContainer()

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 added in v0.12.0 

func (m *SchedulerMetrics) IncTotalApplicationsAccepted()

func (*SchedulerMetrics) IncTotalApplicationsCompleted 

func (m *SchedulerMetrics) IncTotalApplicationsCompleted()

func (*SchedulerMetrics) IncTotalApplicationsRejected 

func (m *SchedulerMetrics) IncTotalApplicationsRejected()

func (*SchedulerMetrics) IncTotalApplicationsRunning 

func (m *SchedulerMetrics) IncTotalApplicationsRunning()

func (*SchedulerMetrics) ObserveAppSortingLatency added in v0.9.0 

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

func (*SchedulerMetrics) ObserveNodeSortingLatency 

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

func (*SchedulerMetrics) ObserveQueueSortingLatency added in v0.9.0 

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

func (*SchedulerMetrics) ObserveSchedulingLatency 

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

func (*SchedulerMetrics) ObserveTryNodeLatency added in v0.12.0 

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

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.