INNER CODE UNIT · Go

buildSoakIndexEntry

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

func buildSoakIndexEntry(sessionID string, s *Scenario, result *Result) soakIndexEntry {
	entry := soakIndexEntry{
		Scenario:  s.Name,
		Connector: s.Connector,
		SessionID: sessionID,
		StartedAt: result.StartedAt,
	}
	if len(result.Points) == 0 {
		return entry
	}
	p := result.Points[0]
	entry.MedianMBps = p.Summary.MedianMBPerSec
	entry.P5MBps = p.Summary.P5MBPerSec
	entry.P95MBps = p.Summary.P95MBPerSec
	for _, pp := range p.Prom {
		if pp.RSSBytes > entry.RSSMaxBytes {
			entry.RSSMaxBytes = pp.RSSBytes
		}

View source record →