mirror of https://github.com/jetkvm/kvm.git
Add more metrics
* Configuration load success/timestamp. * Wake-on-Lan packets/errors. Signed-off-by: SuperQ <superq@gmail.com>
This commit is contained in:
parent
4bfbc66ea7
commit
315c1c9f57
23
config.go
23
config.go
|
@ -9,6 +9,8 @@ import (
|
||||||
"github.com/jetkvm/kvm/internal/logging"
|
"github.com/jetkvm/kvm/internal/logging"
|
||||||
"github.com/jetkvm/kvm/internal/network"
|
"github.com/jetkvm/kvm/internal/network"
|
||||||
"github.com/jetkvm/kvm/internal/usbgadget"
|
"github.com/jetkvm/kvm/internal/usbgadget"
|
||||||
|
"github.com/prometheus/client_golang/prometheus"
|
||||||
|
"github.com/prometheus/client_golang/prometheus/promauto"
|
||||||
)
|
)
|
||||||
|
|
||||||
type WakeOnLanDevice struct {
|
type WakeOnLanDevice struct {
|
||||||
|
@ -138,6 +140,21 @@ var (
|
||||||
configLock = &sync.Mutex{}
|
configLock = &sync.Mutex{}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
configSuccess = promauto.NewGauge(
|
||||||
|
prometheus.GaugeOpts{
|
||||||
|
Name: "jetkvm_config_last_reload_successful",
|
||||||
|
Help: "The last configuration load succeeded",
|
||||||
|
},
|
||||||
|
)
|
||||||
|
configSuccessTime = promauto.NewGauge(
|
||||||
|
prometheus.GaugeOpts{
|
||||||
|
Name: "jetkvm_config_last_reload_success_timestamp_seconds",
|
||||||
|
Help: "Timestamp of last successful config load",
|
||||||
|
},
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
func LoadConfig() {
|
func LoadConfig() {
|
||||||
configLock.Lock()
|
configLock.Lock()
|
||||||
defer configLock.Unlock()
|
defer configLock.Unlock()
|
||||||
|
@ -153,6 +170,8 @@ func LoadConfig() {
|
||||||
file, err := os.Open(configPath)
|
file, err := os.Open(configPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Debug().Msg("default config file doesn't exist, using default")
|
logger.Debug().Msg("default config file doesn't exist, using default")
|
||||||
|
configSuccess.Set(1.0)
|
||||||
|
configSuccessTime.SetToCurrentTime()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
defer file.Close()
|
defer file.Close()
|
||||||
|
@ -161,6 +180,7 @@ func LoadConfig() {
|
||||||
loadedConfig := *defaultConfig
|
loadedConfig := *defaultConfig
|
||||||
if err := json.NewDecoder(file).Decode(&loadedConfig); err != nil {
|
if err := json.NewDecoder(file).Decode(&loadedConfig); err != nil {
|
||||||
logger.Warn().Err(err).Msg("config file JSON parsing failed")
|
logger.Warn().Err(err).Msg("config file JSON parsing failed")
|
||||||
|
configSuccess.Set(0.0)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -181,6 +201,9 @@ func LoadConfig() {
|
||||||
|
|
||||||
logging.GetRootLogger().UpdateLogLevel(config.DefaultLogLevel)
|
logging.GetRootLogger().UpdateLogLevel(config.DefaultLogLevel)
|
||||||
|
|
||||||
|
configSuccess.Set(1.0)
|
||||||
|
configSuccessTime.SetToCurrentTime()
|
||||||
|
|
||||||
logger.Info().Str("path", configPath).Msg("config loaded")
|
logger.Info().Str("path", configPath).Msg("config loaded")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
22
wol.go
22
wol.go
|
@ -4,6 +4,24 @@ import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"encoding/binary"
|
"encoding/binary"
|
||||||
"net"
|
"net"
|
||||||
|
|
||||||
|
"github.com/prometheus/client_golang/prometheus"
|
||||||
|
"github.com/prometheus/client_golang/prometheus/promauto"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
wolPackets = promauto.NewCounter(
|
||||||
|
prometheus.CounterOpts{
|
||||||
|
Name: "jetkvm_wol_sent_packets_total",
|
||||||
|
Help: "Total number of Wake-on-LAN magic packets sent.",
|
||||||
|
},
|
||||||
|
)
|
||||||
|
wolErrors = promauto.NewCounter(
|
||||||
|
prometheus.CounterOpts{
|
||||||
|
Name: "jetkvm_wol_sent_packet_errors_total",
|
||||||
|
Help: "Total number of Wake-on-LAN magic packets errors.",
|
||||||
|
},
|
||||||
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
// SendWOLMagicPacket sends a Wake-on-LAN magic packet to the specified MAC address
|
// SendWOLMagicPacket sends a Wake-on-LAN magic packet to the specified MAC address
|
||||||
|
@ -11,6 +29,7 @@ func rpcSendWOLMagicPacket(macAddress string) error {
|
||||||
// Parse the MAC address
|
// Parse the MAC address
|
||||||
mac, err := net.ParseMAC(macAddress)
|
mac, err := net.ParseMAC(macAddress)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
wolErrors.Inc()
|
||||||
return ErrorfL(wolLogger, "invalid MAC address", err)
|
return ErrorfL(wolLogger, "invalid MAC address", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -20,6 +39,7 @@ func rpcSendWOLMagicPacket(macAddress string) error {
|
||||||
// Set up UDP connection
|
// Set up UDP connection
|
||||||
conn, err := net.Dial("udp", "255.255.255.255:9")
|
conn, err := net.Dial("udp", "255.255.255.255:9")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
wolErrors.Inc()
|
||||||
return ErrorfL(wolLogger, "failed to establish UDP connection", err)
|
return ErrorfL(wolLogger, "failed to establish UDP connection", err)
|
||||||
}
|
}
|
||||||
defer conn.Close()
|
defer conn.Close()
|
||||||
|
@ -27,10 +47,12 @@ func rpcSendWOLMagicPacket(macAddress string) error {
|
||||||
// Send the packet
|
// Send the packet
|
||||||
_, err = conn.Write(packet)
|
_, err = conn.Write(packet)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
wolErrors.Inc()
|
||||||
return ErrorfL(wolLogger, "failed to send WOL packet", err)
|
return ErrorfL(wolLogger, "failed to send WOL packet", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
wolLogger.Info().Str("mac", macAddress).Msg("WOL packet sent")
|
wolLogger.Info().Str("mac", macAddress).Msg("WOL packet sent")
|
||||||
|
wolPackets.Inc()
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue