diff --git a/cmd/perf/internal/managed/managed.go b/cmd/perf/internal/managed/managed.go index 924c14e..eff0028 100644 --- a/cmd/perf/internal/managed/managed.go +++ b/cmd/perf/internal/managed/managed.go @@ -120,7 +120,9 @@ func applyResources(mrTemplatePaths map[string]int, applyInterval time.Duration) if err := runApplyCommand(f); err != nil { return nil, err } - time.Sleep(applyInterval) + if i != count { + time.Sleep(applyInterval) + } tmpFiles = append(tmpFiles, f.Name()) } } @@ -319,7 +321,7 @@ func runCommand(command string) error { sc := bufio.NewScanner(stdout) sc.Split(bufio.ScanLines) for sc.Scan() { - fmt.Println(sc.Text()) + log.Info(sc.Text()) } if err := cmd.Wait(); err != nil { return errors.Wrap(err, "cannot wait for the command exit") diff --git a/cmd/perf/internal/quantify.go b/cmd/perf/internal/quantify.go index 6b2b7db..3ef2f44 100644 --- a/cmd/perf/internal/quantify.go +++ b/cmd/perf/internal/quantify.go @@ -71,7 +71,7 @@ func NewCmdQuantify() *cobra.Command { o.cmd.Flags().DurationVar(&o.stepDuration, "step-duration", 1*time.Second, "Step duration between two data points") o.cmd.Flags().BoolVar(&o.clean, "clean", true, "Delete deployed MRs") o.cmd.Flags().StringVar(&o.nodeIP, "node", "", "Node IP") - o.cmd.Flags().DurationVar(&o.applyInterval, "apply-interval", 0*time.Second, "Elapsed time between applying two manifests to the cluster") + o.cmd.Flags().DurationVar(&o.applyInterval, "apply-interval", 0*time.Second, "Elapsed time between applying two manifests to the cluster. Example = 10s. This means that examples will be applied every 10 seconds.") o.cmd.Flags().DurationVar(&o.timeout, "timeout", 120*time.Minute, "Timeout for the experiment") if err := o.cmd.MarkFlagRequired("provider-pods"); err != nil {