metrics

Documentation

Index

• func GetHandler(collector prometheus.Collector) http.Handler
• func NewCollector(client *v3.Client) prometheus.Collector
• func UpdateLeader(flag bool)
• func UpdateNodeRebootStatus(nodeStatus map[string]map[string]bool)
• func UpdateOperationPhase(phase cke.OperationPhase, ts time.Time)
• func UpdateRebootQueueEntries(numEntries int)
• func UpdateRebootQueueItems(counts map[string]int)
• func UpdateSabakanIntegration(isSuccessful bool, workersByRole map[string]int, unusedMachines int, ...)

Functions

func GetHandler

func GetHandler(collector prometheus.Collector) http.Handler

GetHandler returns http.Handler for prometheus metrics.

func NewCollector

func NewCollector(client *v3.Client) prometheus.Collector

NewCollector returns a new prometheus.Collector.

func UpdateLeader

func UpdateLeader(flag bool)

UpdateLeader updates "leader".

func UpdateNodeRebootStatus

func UpdateNodeRebootStatus(nodeStatus map[string]map[string]bool)

UpdateNodeRebootStatus updates "node_reboot_status".

func UpdateOperationPhase

func UpdateOperationPhase(phase cke.OperationPhase, ts time.Time)

UpdateOperationPhase updates "operation_phase" and its timestamp.

func UpdateRebootQueueEntries

func UpdateRebootQueueEntries(numEntries int)

UpdateRebootQueueEntries updates "reboot_queue_entries".

func UpdateRebootQueueItems

func UpdateRebootQueueItems(counts map[string]int)

UpdateRebootQueueItems updates "reboot_queue_items".

func UpdateSabakanIntegration

func UpdateSabakanIntegration(isSuccessful bool, workersByRole map[string]int, unusedMachines int, ts time.Time)

UpdateSabakanIntegration updates Sabakan integration metrics.