Documentation
¶
Index ¶
- Constants
- func DispatchedPodsInc(podProperty *api.PodProperty, scheduler string)
- func DispatcherGoroutinesDec()
- func DispatcherGoroutinesInc()
- func DispatcherIncomingPodsInc(podProperty *api.PodProperty)
- func DispatchingAttemptsInc(result string)
- func E2EDispatchingLatencyObserve(duration float64)
- func E2EDispatchingLatencyQuantileObserve(duration float64)
- func NodeInPartitionSizeDec(stype, scheduler string)
- func NodeInPartitionSizeInc(stype, scheduler string)
- func ObservePodDispatchingLatency(duration float64)
- func ObservePodUpdatingAttemptAndLatency(podProperty *api.PodProperty, result string, duration float64)
- func PendingPodsAdd(podProperty *api.PodProperty, queue string, value float64)
- func PendingPodsDec(podProperty *api.PodProperty, queue string)
- func PendingPodsInc(podProperty *api.PodProperty, queue string)
- func PendingPodsReset()
- func PendingPodsSet(podProperty *api.PodProperty, queue string, value float64)
- func PendingUnitsSet(unitProperty api.UnitProperty, queue string, value float64)
- func PodDispatched(duration float64)
- func PodDispatchingFailure(duration float64)
- func PodPendingLatencyObserve(podProperty *api.PodProperty, queue string, duration float64)
- func PodShufflingCountInc()
- func PodUpdatingAttemptsInc(podProperty *api.PodProperty, result string)
- func PodUpdatingLatencyObserve(podProperty *api.PodProperty, result string, duration float64)
- func PodsInPartitionSizeDec(scheduler, state string)
- func PodsInPartitionSizeInc(scheduler, state string)
- func QueueSortingLatencyObserve(podProperty *api.PodProperty, queue string, duration float64)
- func Register()
- func SchedulerSizeDec(stype string)
- func SchedulerSizeInc(stype string)
- func SelectingSchedulerLatencyObserve(result string, duration float64)
- func UnitPendingDurationObserve(unitProperty api.UnitProperty, queue string, duration float64)
- type DispatchResult
- type PendingPodsRecorder
Constants ¶
const ( // DispatcherSubsystem - subsystem name used by dispatcher DispatcherSubsystem = "dispatcher" // ActiveScheduler - scheduler type label value ActiveScheduler = "active" // InactiveScheduler - scheduler type label value InactiveScheduler = "inactive" // SuccessResult - result label value SuccessResult = "success" // FailureResult - result label value FailureResult = "failure" )
Variables ¶
This section is empty.
Functions ¶
func DispatchedPodsInc ¶
func DispatchedPodsInc(podProperty *api.PodProperty, scheduler string)
DispatchedPodsInc Invoke Inc method
func DispatcherGoroutinesDec ¶
func DispatcherGoroutinesDec()
func DispatcherGoroutinesInc ¶
func DispatcherGoroutinesInc()
func DispatcherIncomingPodsInc ¶
func DispatcherIncomingPodsInc(podProperty *api.PodProperty)
DispatcherIncomingPodsInc Invoke Inc method podLabels contains basic object property labels
func DispatchingAttemptsInc ¶
func DispatchingAttemptsInc(result string)
DispatchingAttemptsInc Invoke Inc method
func E2EDispatchingLatencyObserve ¶
func E2EDispatchingLatencyObserve(duration float64)
func E2EDispatchingLatencyQuantileObserve ¶
func E2EDispatchingLatencyQuantileObserve(duration float64)
func NodeInPartitionSizeDec ¶
func NodeInPartitionSizeDec(stype, scheduler string)
NodeInPartitionSizeDec Invoke Dec method
func NodeInPartitionSizeInc ¶
func NodeInPartitionSizeInc(stype, scheduler string)
NodeInPartitionSizeInc Invoke Inc method
func ObservePodDispatchingLatency ¶
func ObservePodDispatchingLatency(duration float64)
func ObservePodUpdatingAttemptAndLatency ¶
func ObservePodUpdatingAttemptAndLatency(podProperty *api.PodProperty, result string, duration float64)
func PendingPodsAdd ¶
func PendingPodsAdd(podProperty *api.PodProperty, queue string, value float64)
PendingPodsAdd Invoke Add method podLabels contains basic object property labels
func PendingPodsDec ¶
func PendingPodsDec(podProperty *api.PodProperty, queue string)
PendingPodsDec Invoke Dec method podLabels contains basic object property labels
func PendingPodsInc ¶
func PendingPodsInc(podProperty *api.PodProperty, queue string)
PendingPodsInc Invoke Inc method podLabels contains basic object property labels
func PendingPodsReset ¶
func PendingPodsReset()
func PendingPodsSet ¶
func PendingPodsSet(podProperty *api.PodProperty, queue string, value float64)
PendingPodsSet Invoke Set method podLabels contains basic object property labels
func PendingUnitsSet ¶
func PendingUnitsSet(unitProperty api.UnitProperty, queue string, value float64)
func PodDispatched ¶
func PodDispatched(duration float64)
PodDispatched can record a successful dispatching attempt and the duration since `start`.
func PodDispatchingFailure ¶
func PodDispatchingFailure(duration float64)
PodDispatchingFailure can record a failed dispatching attempt and the duration since `start`.
func PodPendingLatencyObserve ¶
func PodPendingLatencyObserve(podProperty *api.PodProperty, queue string, duration float64)
PodPendingLatencyObserve Invoke Observe method podLabels contains basic object property labels
func PodShufflingCountInc ¶
func PodShufflingCountInc()
func PodUpdatingAttemptsInc ¶
func PodUpdatingAttemptsInc(podProperty *api.PodProperty, result string)
PodUpdatingAttemptsInc Invoke Inc method podLabels contains basic object property labels
func PodUpdatingLatencyObserve ¶
func PodUpdatingLatencyObserve(podProperty *api.PodProperty, result string, duration float64)
PodUpdatingLatencyObserve Invoke Observe method podLabels contains basic object property labels
func PodsInPartitionSizeDec ¶
func PodsInPartitionSizeDec(scheduler, state string)
PodsInPartitionSizeDec Invoke Dec method
func PodsInPartitionSizeInc ¶
func PodsInPartitionSizeInc(scheduler, state string)
PodsInPartitionSizeInc Invoke Inc method
func QueueSortingLatencyObserve ¶
func QueueSortingLatencyObserve(podProperty *api.PodProperty, queue string, duration float64)
QueueSortingLatencyObserve Invoke Observe method podLabels contains basic object property labels
func SelectingSchedulerLatencyObserve ¶
SelectingSchedulerLatencyObserve Invoke Observe method
func UnitPendingDurationObserve ¶
func UnitPendingDurationObserve(unitProperty api.UnitProperty, queue string, duration float64)
Types ¶
type DispatchResult ¶
type DispatchResult string
This file contains helpers for metrics that are associated to a profile.
var ( // DispatchedResult is marked as successful dispatching with feasible scheduler DispatchedResult DispatchResult = "dispatched" // ErrorResult is marked as internal error ErrorResult DispatchResult = "error" )
type PendingPodsRecorder ¶
type PendingPodsRecorder struct {
// contains filtered or unexported fields
}
PendingPodsRecorder is an implementation of MetricRecorder
func NewPendingPodsRecorder ¶
func NewPendingPodsRecorder(queue string) *PendingPodsRecorder
func (*PendingPodsRecorder) AddingLatencyInSeconds ¶
func (r *PendingPodsRecorder) AddingLatencyInSeconds(obj interface{}, duration float64)
func (*PendingPodsRecorder) Clear ¶
func (r *PendingPodsRecorder) Clear()
Clear set a metric counter to 0, in an atomic way
func (*PendingPodsRecorder) Dec ¶
func (r *PendingPodsRecorder) Dec(obj interface{})
Dec decreases a metric counter by 1, in an atomic way
func (*PendingPodsRecorder) Inc ¶
func (r *PendingPodsRecorder) Inc(obj interface{})
Inc increases a metric counter by 1, in an atomic way
Source Files