mirror of
https://github.com/mulgadc/spinifex.git
synced 2026-10-15 09:01:31 +00:00
Julian Sommer
31 lines
909 B
Go
31 lines
909 B
Go
//go:build e2e
|
|
|
|
package harness
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"testing"
|
|
)
|
|
|
|
// LocalStateRevision reads the daemon's local state revision via /local/status.
|
|
// AssertMonotonic uses it to verify a fault didn't rewind persisted state.
|
|
func LocalStateRevision(ctx context.Context, d *DaemonClient, node Node) (uint64, error) {
|
|
s, err := d.Status(ctx, node)
|
|
if err != nil {
|
|
return 0, fmt.Errorf("e2e harness: local state revision %s: %w", node.Name, err)
|
|
}
|
|
return s.Revision, nil
|
|
}
|
|
|
|
// AssertMonotonic fails t if after is strictly less than before. Equal
|
|
// revisions are permitted because a scenario that exercises a read-only
|
|
// fault (e.g. NATS kill with no instance mutations) should see the revision
|
|
// unchanged.
|
|
func AssertMonotonic(t *testing.T, before, after uint64) {
|
|
t.Helper()
|
|
if after < before {
|
|
t.Fatalf("e2e harness: local state revision regressed: before=%d after=%d", before, after)
|
|
}
|
|
}
|