monitoring

Documentation

Index

• Variables
• func NewMetricsLogger(url string, p time.Duration, restrict map[string]bool, log *log.Logger) *monitor
• func NewNodeOomDetector(nodeMetricsUrl string, log *log.Logger) *oomDetector
• type MetricsMonitor

Variables

var NodeMetricsNames = map[string]bool{
	"node_disk_read_bytes_total":       true,
	"node_disk_reads_completed_total":  true,
	"node_disk_writes_completed_total": true,
	"node_disk_written_bytes_total":    true,

	"node_filefd_allocated": true,
	"node_filefd_maximum":   true,

	"node_load1":  true,
	"node_load5":  true,
	"node_load15": true,

	"node_vmstat_oom_kill": true,
	// contains filtered or unexported fields
}

Functions

func NewMetricsLogger

func NewMetricsLogger(url string, p time.Duration, restrict map[string]bool, log *log.Logger) *monitor

NewMetricsLogger periodically (every p duration) fetches prometheus metrics from the given url and logs them to the given logger. If restrict is provided, only the metrics specified will be logged.

func NewNodeOomDetector

func NewNodeOomDetector(nodeMetricsUrl string, log *log.Logger) *oomDetector

Types

type MetricsMonitor

type MetricsMonitor interface {
	// Go starts monitoring of metrics using the given context.
	// Typically Go would never return until context cancellation and hence should be run in a goroutine.
	Go(ctx context.Context)
}