mirror of
https://github.com/henrygd/beszel.git
synced 2026-09-21 17:07:47 +02:00
917d069ab3
- track pool capacity, health, I/O, scrub status, and vdev errors - report dataset usage and correct ZFS filesystem metrics - add pool charts, detail views, refresh controls, and health alerts - persist pool details and include ZFS usage in disk alerts - support configurable detail intervals and legacy agent compatibility --------- Co-authored-by: hank <hank@henrygd.me>
91 lines
2.6 KiB
Go
91 lines
2.6 KiB
Go
//go:build testing && linux
|
|
|
|
package zfs
|
|
|
|
import (
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestPoolKernelStats(t *testing.T) {
|
|
root := t.TempDir()
|
|
oldPath := procZfsPath
|
|
procZfsPath = root
|
|
t.Cleanup(func() { procZfsPath = oldPath })
|
|
|
|
poolDir := filepath.Join(root, "tank")
|
|
require.NoError(t, os.MkdirAll(poolDir, 0o755))
|
|
require.NoError(t, os.WriteFile(filepath.Join(poolDir, "io"), []byte(
|
|
"11 3 0x00 1 80 0 0\n"+
|
|
"nread nwritten reads writes wtime wlentime wupdate rtime rlentime rupdate wcnt rcnt\n"+
|
|
"1884160 6450688 22 978 0 0 0 0 0 0 0 0\n",
|
|
), 0o644))
|
|
require.NoError(t, os.WriteFile(filepath.Join(poolDir, "state"), []byte("DEGRADED\n"), 0o644))
|
|
|
|
stats, err := PoolKernelStats()
|
|
require.NoError(t, err)
|
|
require.Len(t, stats, 1)
|
|
assert.Equal(t, PoolKernelStat{
|
|
Name: "tank", Health: "DEGRADED", NRead: 1884160, NWrite: 6450688,
|
|
}, stats[0])
|
|
}
|
|
|
|
func TestPoolKernelStatsOpenZfs24(t *testing.T) {
|
|
root := t.TempDir()
|
|
oldPath := procZfsPath
|
|
procZfsPath = root
|
|
t.Cleanup(func() { procZfsPath = oldPath })
|
|
|
|
poolDir := filepath.Join(root, "tank")
|
|
require.NoError(t, os.MkdirAll(poolDir, 0o755))
|
|
require.NoError(t, os.WriteFile(filepath.Join(poolDir, "state"), []byte("ONLINE\n"), 0o644))
|
|
require.NoError(t, os.WriteFile(filepath.Join(poolDir, "objset-0x1"), []byte(
|
|
"34 1 0x01 28 7872 0 0\n"+
|
|
"name type data\n"+
|
|
"dataset_name 7 tank\n"+
|
|
"nwritten 4 2000\n"+
|
|
"nread 4 1000\n",
|
|
), 0o644))
|
|
require.NoError(t, os.WriteFile(filepath.Join(poolDir, "objset-0x2"), []byte(
|
|
"34 1 0x01 28 7872 0 0\n"+
|
|
"name type data\n"+
|
|
"dataset_name 7 tank/videos\n"+
|
|
"nwritten 4 400\n"+
|
|
"nread 4 300\n",
|
|
), 0o644))
|
|
|
|
stats, err := PoolKernelStats()
|
|
require.NoError(t, err)
|
|
require.Len(t, stats, 1)
|
|
assert.Equal(t, PoolKernelStat{
|
|
Name: "tank", Health: "ONLINE", NRead: 1300, NWrite: 2400,
|
|
}, stats[0])
|
|
}
|
|
|
|
func TestPoolKernelStatsNoZfs(t *testing.T) {
|
|
oldPath := procZfsPath
|
|
procZfsPath = t.TempDir()
|
|
t.Cleanup(func() { procZfsPath = oldPath })
|
|
|
|
_, err := PoolKernelStats()
|
|
assert.ErrorIs(t, err, ErrNoZfs)
|
|
}
|
|
|
|
func TestReadPoolIORejectsMalformedCounters(t *testing.T) {
|
|
path := filepath.Join(t.TempDir(), "io")
|
|
require.NoError(t, os.WriteFile(path, []byte("nread nwritten\nnope 10\n"), 0o644))
|
|
_, _, err := readPoolIO(path)
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestReadObjsetIORequiresAllCounters(t *testing.T) {
|
|
path := filepath.Join(t.TempDir(), "objset-0x1")
|
|
require.NoError(t, os.WriteFile(path, []byte("nread 4 10\n"), 0o644))
|
|
_, _, err := readObjsetIO(path)
|
|
require.Error(t, err)
|
|
}
|