Buriburizaemon/nezha_domains
1
0
Fork 0
mirror of https://github.com/Buriburizaem0n/nezha_domains.git synced 2026-09-19 09:40:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(agentcompat): isolate stress resource sampling

Browse Source 
Co-authored-by: naiba/CloudCode <hi+cloudcode@nai.ba>
This commit is contained in:
naiba
2026-07-20 08:04:17 +00:00
co-authored by naiba/CloudCode
parent a7cf600bd7
commit 5d7fef6408
2 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
integration/agentcompat/internal/scenario/held_session_set_real_fixture.go
+11 -1
View File
@@ -40,7 +40,12 @@ func startHeldSessionSetRealFixture(ctx context.Context, paths contract.Paths, p
fixture.preparedBinary = prepared fixture.preparedBinary = prepared
for ordinal := 1; ordinal <= heldSessionSetAgentCount; ordinal++ { for ordinal := 1; ordinal <= heldSessionSetAgentCount; ordinal++ {
uuid := fmt.Sprintf("00000000-0000-0000-0000-%012d", 700+ordinal) uuid := fmt.Sprintf("00000000-0000-0000-0000-%012d", 700+ordinal)
instance, startErr := agent.Start(ctx, agent.AgentStartConfig{PreparedBinary: prepared, Endpoint: dashboardInstance.Endpoint(), Secret: dashboardInstance.AgentSecret(), UUID: uuid}) startConfig := canonicalHeldSessionAgentStartConfig()
startConfig.PreparedBinary = prepared
startConfig.Endpoint = dashboardInstance.Endpoint()
startConfig.Secret = dashboardInstance.AgentSecret()
startConfig.UUID = uuid
instance, startErr := agent.Start(ctx, startConfig)
if startErr != nil { if startErr != nil {
return nil, fixture.close(ctx, startErr) return nil, fixture.close(ctx, startErr)
} }
@@ -81,6 +86,11 @@ func startHeldSessionSetRealFixture(ctx context.Context, paths contract.Paths, p
return fixture, nil return fixture, nil
} }
func canonicalHeldSessionAgentStartConfig() agent.AgentStartConfig {
// Connection counting opens short-lived NETLINK_INET_DIAG descriptors during state reports; exclude probes from stress residue snapshots.
return agent.AgentStartConfig{SkipConnectionCount: true}
}
func validateHeldSessionSetRealFixture(fixture *heldSessionSetRealFixture, plan StressPlan) error { func validateHeldSessionSetRealFixture(fixture *heldSessionSetRealFixture, plan StressPlan) error {
if fixture == nil || fixture.dashboard == nil || fixture.preparedBinary == nil || len(fixture.agents) != heldSessionSetAgentCount || len(fixture.readiness) != heldSessionSetAgentCount || len(fixture.agentPATs) != heldSessionSetAgentCount || len(fixture.controlServerIDs) != heldSessionSetAgentCount { if fixture == nil || fixture.dashboard == nil || fixture.preparedBinary == nil || len(fixture.agents) != heldSessionSetAgentCount || len(fixture.readiness) != heldSessionSetAgentCount || len(fixture.agentPATs) != heldSessionSetAgentCount || len(fixture.controlServerIDs) != heldSessionSetAgentCount {
return errors.New("held session set real fixture is incomplete") return errors.New("held session set real fixture is incomplete")
integration/agentcompat/internal/scenario/held_session_set_real_support_test.go
+8
View File
@@ -44,6 +44,14 @@ func TestHeldSessionSetRealPlanUsesCanonicalPRFullTopology(t *testing.T) {
} }
} }
func TestCanonicalHeldSessionAgentStartConfig_SkipsConnectionCount(t *testing.T) {
// When
actual := canonicalHeldSessionAgentStartConfig()
// Then
require.True(t, actual.SkipConnectionCount)
}
func TestHeldSessionSetRealEvidenceRejectsIncompleteAndRedactsArtifact(t *testing.T) { func TestHeldSessionSetRealEvidenceRejectsIncompleteAndRedactsArtifact(t *testing.T) {
root := t.TempDir() root := t.TempDir()
require.NoError(t, os.Chmod(root, 0o700)) require.NoError(t, os.Chmod(root, 0o700))