INNER CODE UNIT · Go

buildSoakArchivePlan

redpanda-data/connect · benchmarking/aws/runner/main.go:681

func buildSoakArchivePlan(sessionID, scenarioName, key, brokerArtifact string) soakArchivePlan {
	return soakArchivePlan{
		ResultKey: fmt.Sprintf("runs/%s/result.json", sessionID),
		IndexKey:  fmt.Sprintf("soak-index/%s/%s.json", scenarioName, sessionID),
		RawKeys:   soakRawArtifactKeys(sessionID, key, brokerArtifact),
	}
}

// buildSoakArchivePlanForPoints extends buildSoakArchivePlan to a soak run's
// FULL result.Points rather than just its single measured point: EVERY
// point contributes its own raw artifact keys, not just the first. A
// binary-arm soak (see Scenario.IsBinaryArmScenario) measures multiple
// points in one session — one per arm — and each arm's raw evidence (sweep
// log, Prometheus dump, broker scrape) must be archived, or the PR arm's
// half of the comparison would be silently missing from the archive.
func buildSoakArchivePlanForPoints(sessionID, scenarioName string, points []PointResult, topo Topology) soakArchivePlan {
	plan := soakArchivePlan{
		ResultKey: fmt.Sprintf("runs/%s/result.json", sessionID),

View source record →

📰 Research Paper
Loading…
⏳ Fetching content…