Documentation ¶
Index ¶
- Constants
- func NewInternalMetricsCollector(hcInfo *history.InternalMetricsHistory) *internalMetricsCollector
- func Reset()
- func SinceInSeconds(start time.Time) float64
- type CoreEventMetrics
- type CoreQueueMetrics
- type CoreSchedulerMetrics
- type Metrics
- type QueueMetrics
- func (m *QueueMetrics) AddQueueUsedResourceMetrics(resourceName string, value float64)
- func (m *QueueMetrics) IncApplicationsAccepted()
- func (m *QueueMetrics) IncApplicationsCompleted()
- func (m *QueueMetrics) IncApplicationsRejected()
- func (m *QueueMetrics) SetQueueUsedResourceMetrics(resourceName string, value float64)
- type SchedulerMetrics
- func (m *SchedulerMetrics) AddActiveNodes(value int)
- func (m *SchedulerMetrics) AddAllocatedContainers(value int)
- func (m *SchedulerMetrics) AddFailedNodes(value int)
- func (m *SchedulerMetrics) AddRejectedContainers(value int)
- func (m *SchedulerMetrics) AddReleasedContainers(value int)
- func (m *SchedulerMetrics) AddSchedulingErrors(value int)
- func (m *SchedulerMetrics) AddTotalApplicationsAccepted(value int)
- func (m *SchedulerMetrics) AddTotalApplicationsCompleted(value int)
- func (m *SchedulerMetrics) AddTotalApplicationsRejected(value int)
- func (m *SchedulerMetrics) AddTotalApplicationsRunning(value int)
- func (m *SchedulerMetrics) DecActiveNodes()
- func (m *SchedulerMetrics) DecFailedNodes()
- func (m *SchedulerMetrics) DecTotalApplicationsCompleted()
- func (m *SchedulerMetrics) DecTotalApplicationsRunning()
- func (m *SchedulerMetrics) GetFailedNodes() (int, error)
- func (m *SchedulerMetrics) GetSchedulingErrors() (int, error)
- func (m *SchedulerMetrics) IncActiveNodes()
- func (m *SchedulerMetrics) IncAllocatedContainer()
- func (m *SchedulerMetrics) IncFailedNodes()
- func (m *SchedulerMetrics) IncRejectedContainer()
- func (m *SchedulerMetrics) IncReleasedContainer()
- func (m *SchedulerMetrics) IncSchedulingError()
- func (m *SchedulerMetrics) IncTotalApplicationsAccepted()
- func (m *SchedulerMetrics) IncTotalApplicationsCompleted()
- func (m *SchedulerMetrics) IncTotalApplicationsRejected()
- func (m *SchedulerMetrics) IncTotalApplicationsRunning()
- func (m *SchedulerMetrics) ObserveAppSortingLatency(start time.Time)
- func (m *SchedulerMetrics) ObserveNodeSortingLatency(start time.Time)
- func (m *SchedulerMetrics) ObserveQueueSortingLatency(start time.Time)
- func (m *SchedulerMetrics) ObserveSchedulingLatency(start time.Time)
- func (m *SchedulerMetrics) ObserveTryNodeLatency(start time.Time)
- func (m *SchedulerMetrics) SetActiveNodes(value int)
- func (m *SchedulerMetrics) SetFailedNodes(value int)
- func (m *SchedulerMetrics) SetNodeResourceUsage(resourceName string, rangeIdx int, value float64)
- func (m *SchedulerMetrics) SetTotalApplicationsCompleted(value int)
- func (m *SchedulerMetrics) SetTotalApplicationsRunning(value int)
- func (m *SchedulerMetrics) SubActiveNodes(value int)
- func (m *SchedulerMetrics) SubFailedNodes(value int)
- func (m *SchedulerMetrics) SubTotalApplicationsCompleted(value int)
- func (m *SchedulerMetrics) SubTotalApplicationsRunning(value int)
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 SinceInSeconds ¶
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 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)
Click to show internal directories.
Click to hide internal directories.