metrics

package
v0.0.0-...-e52b029 Latest Latest
Warning

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

Go to latest
Published: Oct 22, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
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 Register

func Register()

Register all metrics.

func SchedulerSizeDec

func SchedulerSizeDec(stype string)

SchedulerSizeDec Invoke Dec method

func SchedulerSizeInc

func SchedulerSizeInc(stype string)

SchedulerSizeInc Invoke Inc method

func SelectingSchedulerLatencyObserve

func SelectingSchedulerLatencyObserve(result string, duration float64)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL