scanner := bufio.NewScanner(file)
scanner.Buffer(make([]byte, 64*1024), buildLineBytes)
+
for scanner.Scan() {
var record ModelUsageRecord
+
err = json.Unmarshal(scanner.Bytes(), &record)
if err != nil {
return nil, fmt.Errorf("decode usage: %w", err)
// buildWriteReport writes the result of a build run.
func buildWriteReport(out io.Writer, appended int, stop string, records []ModelUsageRecord, sizes []int) error {
var input, cached, output, failed int
+
for _, record := range records {
input += record.InputTokens
cached += record.CachedTokens
}
var lines []string
+
if stop != "" {
lines = append(lines, "stopped early: "+stop)
}
}
var events []event
+
seconds := make([]float64, 0, len(records))
total := 0.0
for _, record := range records {
}
wall := events[len(events)-1].at.Sub(events[0].at).Seconds()
+
slices.Sort(seconds)
return fmt.Sprintf("time: %.0f s in all, %.1f calls per minute, %.1f s per call (median %.1f, max %.1f), calls at once: at most %d, %.1f on average", wall, 60*float64(len(seconds))/max(wall, 1e-9), total/float64(len(seconds)), seconds[len(seconds)/2], seconds[len(seconds)-1], most, total/max(wall, 1e-9))