mirror of
https://github.com/mulgadc/spinifex.git
synced 2026-10-19 10:52:04 +00:00
Julian Sommer
44 lines
1.4 KiB
Go
44 lines
1.4 KiB
Go
//go:build e2e
|
|
|
|
package harness
|
|
|
|
import (
|
|
"context"
|
|
"path/filepath"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// DumpAllNodeLogs fans out `journalctl -u 'spinifex-*'` per node into the
|
|
// artifact directory. Used by phase 8/9 on failure and by the package
|
|
// TestMain cleanup as a last-resort post-mortem. Tolerates SSH failure on
|
|
// any node — the log dump is best-effort, not a test gate.
|
|
//
|
|
// File naming: artifactsDir/journal-<nodeName>.log. Existing files are
|
|
// overwritten so repeat runs don't accumulate.
|
|
func DumpAllNodeLogs(t *testing.T, c *Cluster, artifactsDir string) {
|
|
t.Helper()
|
|
ssh := NewPeerSSH()
|
|
for _, n := range c.Nodes {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
|
out, err := ssh.Run(ctx, n.Addr, "journalctl -u 'spinifex-*' -n 500 --no-pager")
|
|
cancel()
|
|
if err != nil {
|
|
t.Logf("DumpAllNodeLogs: %s journalctl: %v (best-effort, skipping)", n.Name, err)
|
|
continue
|
|
}
|
|
path := filepath.Join(artifactsDir, "journal-"+n.Name+".log")
|
|
DumpFile(t, filepath.Dir(path), filepath.Base(path), out)
|
|
}
|
|
}
|
|
|
|
// SpxGetNodesAcrossCluster runs `spx get nodes` best-effort and returns trimmed
|
|
// output. CLI ↔ NATS dial can race the cluster join after a node restart and
|
|
// return "no servers available" even when the data path is healthy; errors are
|
|
// swallowed intentionally.
|
|
func SpxGetNodesAcrossCluster(t *testing.T) string {
|
|
t.Helper()
|
|
return strings.TrimSpace(SpxRunBestEffort(t, "get", "nodes", "--timeout", "5s"))
|
|
}
|