Benson Wong
7e3e94a08a
Add a comprehensive performance monitoring system that collects CPU, memory, swap, load average, network IO, and GPU stats. Provides both a REST API for the UI and a Prometheus /metrics endpoint. Backend changes: - New internal/perf package with configurable interval-based stats collection - GPU monitoring via LACT (Unix socket) and nvidia-smi fallback on Linux - Ring buffer (internal/ring) for time-series stat storage - Prometheus /metrics endpoint with all system and GPU metrics - Moved LogMonitor to internal/logmon package - New PerformanceConfig for hot-reloadable monitoring settings - REST /api/performance endpoint replacing SSE streaming UI changes: - New Performance page with real-time charts for CPU, memory, GPU, and network - Reusable PerformanceChart component - LLAMA_SWAP_URL environment variable support - Improved capture dialog display Other: - Example Grafana dashboard for Prometheus metrics - monitor-test standalone binary - Config schema and example updates fixes #596
66 lines
1.2 KiB
Go
66 lines
1.2 KiB
Go
package ring
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestBuffer_EmptySliceIsNil(t *testing.T) {
|
|
b := NewBuffer[int](4)
|
|
assert.Nil(t, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_PushBelowCapacity(t *testing.T) {
|
|
b := NewBuffer[int](4)
|
|
b.Push(1)
|
|
b.Push(2)
|
|
assert.Equal(t, []int{1, 2}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_PushAtCapacity(t *testing.T) {
|
|
b := NewBuffer[int](3)
|
|
b.Push(1)
|
|
b.Push(2)
|
|
b.Push(3)
|
|
assert.Equal(t, []int{1, 2, 3}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_PushOverCapacityEvictsOldest(t *testing.T) {
|
|
b := NewBuffer[int](3)
|
|
b.Push(1)
|
|
b.Push(2)
|
|
b.Push(3)
|
|
b.Push(4)
|
|
assert.Equal(t, []int{2, 3, 4}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_CapacityOne(t *testing.T) {
|
|
b := NewBuffer[int](1)
|
|
b.Push(1)
|
|
b.Push(2)
|
|
assert.Equal(t, []int{2}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_ZeroCapacityDefaultsToOne(t *testing.T) {
|
|
b := NewBuffer[int](0)
|
|
b.Push(42)
|
|
assert.Equal(t, []int{42}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_SliceReturnsCopy(t *testing.T) {
|
|
b := NewBuffer[int](4)
|
|
b.Push(10)
|
|
s := b.Slice()
|
|
s[0] = 99
|
|
assert.Equal(t, []int{10}, b.Slice())
|
|
}
|
|
|
|
func TestBuffer_InsertionOrderPreservedAfterWrap(t *testing.T) {
|
|
b := NewBuffer[int](4)
|
|
for i := 1; i <= 8; i++ {
|
|
b.Push(i)
|
|
}
|
|
assert.Equal(t, []int{5, 6, 7, 8}, b.Slice())
|
|
}
|