metrics

package
v0.0.0-...-d12ace5 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2024 License: Apache-2.0 Imports: 10 Imported by: 35

Documentation

Index

Constants

View Source
const (
	OpenFileDescriptorsMetric = "OpenFileDescriptors"
	FileDescriptorUnits       = "descriptors"
)
View Source
const (
	DefaultEmitMetricsFrequency = 15 * time.Second

	ConvergenceLRPRunsMetric     = "ConvergenceLRPRuns"
	ConvergenceLRPDurationMetric = "ConvergenceLRPDuration"

	LRPsUnclaimedMetric     = "LRPsUnclaimed"
	LRPsClaimedMetric       = "LRPsClaimed"
	LRPsRunningMetric       = "LRPsRunning"
	CrashedActualLRPsMetric = "CrashedActualLRPs"
	LRPsMissingMetric       = "LRPsMissing"
	LRPsExtraMetric         = "LRPsExtra"

	SuspectRunningLRPsMetric = "SuspectRunningActualLRPs"
	SuspectClaimedLRPsMetric = "SuspectClaimedActualLRPs"

	LRPsDesiredMetric         = "LRPsDesired"
	CrashingDesiredLRPsMetric = "CrashingDesiredLRPs"

	PresentCellsMetric = "PresentCells"
	SuspectCellsMetric = "SuspectCells"
)
View Source
const (
	DefaultTaskEmitMetricsFrequency = 15 * time.Second

	ConvergenceTaskRunsMetric     = "ConvergenceTaskRuns"
	ConvergenceTaskDurationMetric = "ConvergenceTaskDuration"

	TasksStartedMetric   = "TasksStarted"
	TasksSucceededMetric = "TasksSucceeded"
	TasksFailedMetric    = "TasksFailed"

	TasksPendingMetric   = "TasksPending"
	TasksRunningMetric   = "TasksRunning"
	TasksCompletedMetric = "TasksCompleted"
	TasksResolvingMetric = "TasksResolving"

	ConvergenceTasksPrunedMetric = "ConvergenceTasksPruned"
	ConvergenceTasksKickedMetric = "ConvergenceTasksKicked"
)
View Source
const (
	DefaultEmitFrequency = 60 * time.Second
)

Variables

This section is empty.

Functions

func NewBBSElectionMetronNotifier

func NewBBSElectionMetronNotifier(logger lager.Logger, metronClient loggingclient.IngressClient) ifrit.Runner

func NewDBStatMetronNotifier

func NewDBStatMetronNotifier(logger lager.Logger, clock clock.Clock, dbStats DBStats, metronClient logging.IngressClient, monitor monitor.Monitor) ifrit.Runner

func NewFileDescriptorMetronNotifier

func NewFileDescriptorMetronNotifier(logger lager.Logger, newTicker clock.Ticker, metronClient loggingclient.IngressClient, procPath string) ifrit.Runner

Types

type BBSElectionMetronNotifier

type BBSElectionMetronNotifier struct {
	Logger lager.Logger
	// contains filtered or unexported fields
}

func (BBSElectionMetronNotifier) Run

func (notifier BBSElectionMetronNotifier) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type DBStats

type DBStats interface {
	OpenConnections() int
	WaitDuration() time.Duration
	WaitCount() int64
}

type FileDescriptorMetronNotifier

type FileDescriptorMetronNotifier struct {
	Logger lager.Logger
	// contains filtered or unexported fields
}

func (FileDescriptorMetronNotifier) Run

func (notifier FileDescriptorMetronNotifier) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type LRPStatMetronNotifier

type LRPStatMetronNotifier interface {
	ifrit.Runner

	RecordFreshDomains(domains []string)
	RecordConvergenceDuration(duration time.Duration)
	RecordLRPCounts(
		unclaimed, claimed, running, crashed, missing, extra,
		suspectRunning, suspectClaimed, desired, crashingDesired int,
	)
	RecordCellCounts(present, suspect int)
}

func NewLRPStatMetronNotifier

func NewLRPStatMetronNotifier(logger lager.Logger, clock clock.Clock, metronClient logging.IngressClient) LRPStatMetronNotifier

type RequestStatMetronNotifier

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

func NewRequestStatMetronNotifier

func NewRequestStatMetronNotifier(logger lager.Logger, ticker clock.Ticker, metronClient loggingclient.IngressClient) *RequestStatMetronNotifier

func (*RequestStatMetronNotifier) IncrementRequestCounter

func (notifier *RequestStatMetronNotifier) IncrementRequestCounter(delta int)

func (*RequestStatMetronNotifier) ReadAndResetLatency

func (notifier *RequestStatMetronNotifier) ReadAndResetLatency() time.Duration

func (*RequestStatMetronNotifier) Run

func (notifier *RequestStatMetronNotifier) Run(signals <-chan os.Signal, ready chan<- struct{}) error

func (*RequestStatMetronNotifier) UpdateLatency

func (notifier *RequestStatMetronNotifier) UpdateLatency(latency time.Duration)

type TaskStatMetronNotifier

type TaskStatMetronNotifier interface {
	ifrit.Runner

	RecordConvergenceDuration(duration time.Duration)
	RecordTaskStarted(cellID string)
	RecordTaskSucceeded(cellID string)
	RecordTaskFailed(cellID string)
	RecordTaskCounts(pending, running, completed, resolved int, pruned, kicked uint64)
}

func NewTaskStatMetronNotifier

func NewTaskStatMetronNotifier(logger lager.Logger, clock clock.Clock, metronClient logging.IngressClient) TaskStatMetronNotifier

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

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