mirror of https://github.com/jetkvm/kvm.git
Fix: go lint errors
This commit is contained in:
parent
0ed84257f6
commit
0e1c896aa2
|
@ -229,14 +229,14 @@ var (
|
||||||
lastMetricsUpdate time.Time
|
lastMetricsUpdate time.Time
|
||||||
|
|
||||||
// Counter value tracking (since prometheus counters don't have Get() method)
|
// Counter value tracking (since prometheus counters don't have Get() method)
|
||||||
audioFramesReceivedValue int64
|
audioFramesReceivedValue int64
|
||||||
audioFramesDroppedValue int64
|
audioFramesDroppedValue int64
|
||||||
audioBytesProcessedValue int64
|
audioBytesProcessedValue int64
|
||||||
audioConnectionDropsValue int64
|
audioConnectionDropsValue int64
|
||||||
micFramesSentValue int64
|
micFramesSentValue int64
|
||||||
micFramesDroppedValue int64
|
micFramesDroppedValue int64
|
||||||
micBytesProcessedValue int64
|
micBytesProcessedValue int64
|
||||||
micConnectionDropsValue int64
|
micConnectionDropsValue int64
|
||||||
)
|
)
|
||||||
|
|
||||||
// UpdateAudioMetrics updates Prometheus metrics with current audio data
|
// UpdateAudioMetrics updates Prometheus metrics with current audio data
|
||||||
|
@ -407,4 +407,4 @@ func StartMetricsUpdater() {
|
||||||
UpdateMicrophoneConfigMetrics(micConfig)
|
UpdateMicrophoneConfigMetrics(micConfig)
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|
|
@ -26,12 +26,12 @@ type ProcessMetrics struct {
|
||||||
|
|
||||||
// ProcessMonitor monitors CPU and memory usage of processes
|
// ProcessMonitor monitors CPU and memory usage of processes
|
||||||
type ProcessMonitor struct {
|
type ProcessMonitor struct {
|
||||||
logger zerolog.Logger
|
logger zerolog.Logger
|
||||||
mutex sync.RWMutex
|
mutex sync.RWMutex
|
||||||
monitoredPIDs map[int]*processState
|
monitoredPIDs map[int]*processState
|
||||||
running bool
|
running bool
|
||||||
stopChan chan struct{}
|
stopChan chan struct{}
|
||||||
metricsChan chan ProcessMetrics
|
metricsChan chan ProcessMetrics
|
||||||
updateInterval time.Duration
|
updateInterval time.Duration
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -201,11 +201,11 @@ func (pm *ProcessMonitor) collectMetrics(pid int, state *processState) (ProcessM
|
||||||
if !state.lastSample.IsZero() {
|
if !state.lastSample.IsZero() {
|
||||||
timeDelta := now.Sub(state.lastSample).Seconds()
|
timeDelta := now.Sub(state.lastSample).Seconds()
|
||||||
cpuDelta := float64(totalCPUTime - state.lastCPUTime)
|
cpuDelta := float64(totalCPUTime - state.lastCPUTime)
|
||||||
|
|
||||||
// Convert from clock ticks to seconds (assuming 100 Hz)
|
// Convert from clock ticks to seconds (assuming 100 Hz)
|
||||||
clockTicks := 100.0
|
clockTicks := 100.0
|
||||||
cpuSeconds := cpuDelta / clockTicks
|
cpuSeconds := cpuDelta / clockTicks
|
||||||
|
|
||||||
if timeDelta > 0 {
|
if timeDelta > 0 {
|
||||||
metric.CPUPercent = (cpuSeconds / timeDelta) * 100.0
|
metric.CPUPercent = (cpuSeconds / timeDelta) * 100.0
|
||||||
}
|
}
|
||||||
|
@ -260,4 +260,4 @@ func GetProcessMonitor() *ProcessMonitor {
|
||||||
globalProcessMonitor.Start()
|
globalProcessMonitor.Start()
|
||||||
})
|
})
|
||||||
return globalProcessMonitor
|
return globalProcessMonitor
|
||||||
}
|
}
|
||||||
|
|
|
@ -11,7 +11,7 @@ func initPrometheus() {
|
||||||
// A Prometheus metrics endpoint.
|
// A Prometheus metrics endpoint.
|
||||||
version.Version = builtAppVersion
|
version.Version = builtAppVersion
|
||||||
prometheus.MustRegister(versioncollector.NewCollector("jetkvm"))
|
prometheus.MustRegister(versioncollector.NewCollector("jetkvm"))
|
||||||
|
|
||||||
// Start audio metrics collection
|
// Start audio metrics collection
|
||||||
audio.StartMetricsUpdater()
|
audio.StartMetricsUpdater()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue