/* Copyright 2021 The Kubernetes Authors All rights reserved. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package main import ( "encoding/csv" "fmt" "image/color" "log" "math" "os" "runtime" "strconv" "github.com/pkg/errors" "gonum.org/v1/plot" "gonum.org/v1/plot/plotter" "gonum.org/v1/plot/plotutil" "gonum.org/v1/plot/vg" ) var FOLDER = "site/static/images/benchmarks/cpuUsage/autoPause" type integerTicks struct{} func (integerTicks) Ticks(minimum, maximum float64) []plot.Tick { var t []plot.Tick for i := math.Trunc(minimum); i <= maximum; i += 50 { t = append(t, plot.Tick{Value: i, Label: fmt.Sprint(i)}) } return t } func main() { if err := execute(); err != nil { fmt.Println(err) os.Exit(1) } } func execute() error { // sessionID is generated and used at cpu usage benchmark if len(os.Args) <= 1 || len(os.Args[1]) == 0 { return errors.New("Please identify sessionID") } sessionID := os.Args[1] // Create plot instance p := plot.New() // Set view options switch runtime.GOOS { case "darwin": p.Title.Text = "CPU% Busy Overhead - With Auto Pause vs. Non Auto Pause (less is better)" case "linux": p.Title.Text = "CPU% Busy Overhead - With Auto Pause vs. Non Auto Pause (less is better)" } p.Y.Label.Text = "CPU overhead%" // Open non-autopause csv file of benchmark summary napResults := []float64{} napFn := "./out/benchmark-results/" + sessionID + "/cstat.nonautopause.summary" napFile, err := os.Open(napFn) if err != nil { return errors.Wrap(err, "Missing summary csv") } defer napFile.Close() // Read result values from benchmark summary csv napReader := csv.NewReader(napFile) var napLine []string for { napLine, err = napReader.Read() if err != nil { break } s, err := strconv.ParseFloat(napLine[0], 64) if err != nil { return errors.Wrap(err, "Failed to convert to float64") } napResults = append(napResults, s) } // Open auto-pause csv file of benchmark summary apResults := []float64{} apFn := "./out/benchmark-results/" + sessionID + "/cstat.autopause.summary" apFile, err := os.Open(apFn) if err != nil { return errors.Wrap(err, "Missing summary csv") } defer apFile.Close() // Read result values from benchmark summary csv apReader := csv.NewReader(apFile) var apLine []string for { apLine, err = apReader.Read() if err != nil { break } s, err := strconv.ParseFloat(apLine[0], 64) if err != nil { return errors.Wrap(err, "Failed to convert to float64") } apResults = append(apResults, s) } // Set bar graph width breadth := vg.Points(40) // Create Bar instance with non-autopause benchmark results barNAP, err := plotter.NewBarChart(plotter.Values(napResults), breadth) if err != nil { return errors.Wrap(err, "Failed to create bar chart") } // Set border of the bar graph. 0 is no border color barNAP.LineStyle.Width = vg.Length(0) // Add bar name p.Legend.Add("Initial Start CPU usage Before Pause", barNAP) // Set bar color to gray. barNAP.Color = color.RGBA{184, 184, 184, 255} // Create Bar instance with auto-pause benchmark results barAP, err := plotter.NewBarChart(plotter.Values(apResults), breadth) if err != nil { return errors.Wrap(err, "Failed to create bar chart") } // Set border of the bar graph. 0 is no border color barAP.LineStyle.Width = vg.Length(0) // Add bar name p.Legend.Add("Auto Paused CPU usage", barAP) // Set bar color. 1 is green barAP.Color = plotutil.Color(1) hb := vg.Points(20) barNAP.Offset = -hb barAP.Offset = hb p.Add(barNAP, barAP) // Set legend position upper p.Legend.Top = true // Add x-lay names switch runtime.GOOS { case "darwin": p.NominalX("OS idle", "minikube hyperkit", "minikube virtualbox", "minikube docker", "Docker for Mac Kubernetes", "k3d", "kind") case "linux": p.NominalX("OS idle", "minikube kvm2", "minikube virtualbox", "minikube docker", "Docker idle", "k3d", "kind") } // Set non-autopause data label to each bar var napLabels []string for i := range napResults { nLabel := strconv.FormatFloat(napResults[i], 'f', -1, 64) napLabels = append(napLabels, nLabel) } var napCPU []plotter.XY for i := range napResults { napXPos := float64(i) - 0.25 napYPos := napResults[i] + 0.1 napXY := plotter.XY{X: napXPos, Y: napYPos} napCPU = append(napCPU, napXY) } // CPU Busy% non-autopause data label napl, err := plotter.NewLabels(plotter.XYLabels{ XYs: napCPU, Labels: napLabels, }, ) if err != nil { return err } // Set auto-pause data label to each bar var apLabels []string for i := range apResults { if apResults[i] == 0 { apLabels = append(apLabels, "N/A") } else { apLabel := strconv.FormatFloat(apResults[i], 'f', -1, 64) apLabels = append(apLabels, apLabel) } } var apCPU []plotter.XY for i := range apResults { apXPos := float64(i) + 0.05 apYPos := apResults[i] + 0.1 apXY := plotter.XY{X: apXPos, Y: apYPos} apCPU = append(apCPU, apXY) } // CPU Busy% auto-pause data label apl, err := plotter.NewLabels(plotter.XYLabels{ XYs: apCPU, Labels: apLabels, }, ) if err != nil { return err } // define max cpu busy% to 20% p.Y.Max = 20 p.Y.Tick.Marker = integerTicks{} // Add CPU Busy% label to plot p.Add(napl, apl) // Output bar graph switch runtime.GOOS { case "darwin": if err := p.Save(13*vg.Inch, 8*vg.Inch, FOLDER+"/mac.png"); err != nil { return errors.Wrap(err, "Failed to create bar graph png") } log.Printf("Generated graph png to %s/mac.png", FOLDER) case "linux": if err := p.Save(13*vg.Inch, 10*vg.Inch, FOLDER+"/linux.png"); err != nil { return errors.Wrap(err, "Failed to create bar graph png") } log.Printf("Generated graph png to %s/linux.png", FOLDER) } return nil }