INNER CODE UNIT · Go
uploadSoakResult
redpanda-data/connect · benchmarking/aws/runner/main.go:734
func uploadSoakResult(ctx context.Context, region, sessionBucket, archiveBucket, sessionID string, s *Scenario, result *Result, jsonPath string, topo Topology, logFetcher LogFetcher) (soakIndexEntry, error) {
entry := buildSoakIndexEntry(sessionID, s, result)
entry.BuildSHA = gitHeadSHA()
if archiveBucket == "" {
return entry, errors.New("no soak archive bucket configured (--soak-archive-bucket)")
}
cfg, err := awsconfig.LoadDefaultConfig(ctx, awsconfig.WithRegion(region))
if err != nil {
return entry, err
}
client := s3.NewFromConfig(cfg)
plan := buildSoakArchivePlanForPoints(sessionID, s.Name, result.Points, topo)
raw, err := os.ReadFile(jsonPath)
if err != nil {
return entry, fmt.Errorf("read local result JSON %s: %w", jsonPath, err)
}