INNER CODE UNIT · Go

buildSoakArchivePlanForPoints

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

func buildSoakArchivePlanForPoints(sessionID, scenarioName string, points []PointResult, topo Topology) soakArchivePlan {
	plan := soakArchivePlan{
		ResultKey: fmt.Sprintf("runs/%s/result.json", sessionID),
		IndexKey:  fmt.Sprintf("soak-index/%s/%s.json", scenarioName, sessionID),
	}
	for _, p := range points {
		key := sweepPoint{VCPU: p.VCPU, ArmID: p.Arm}.Key()
		var brokerArtifact string
		if topo != nil {
			brokerArtifact = topo.MetricArtifact(key)
		}
		plan.RawKeys = append(plan.RawKeys, soakRawArtifactKeys(sessionID, key, brokerArtifact)...)
	}
	return plan
}

// uploadSoakResult archives a soak run's full result JSON, a soakIndexEntry
// summary, and its raw per-point artifacts (sweep log, Prometheus dump,

View source record →