diff --git a/pkg/bench/get.go b/pkg/bench/get.go index 23eb9bae..ea723d76 100644 --- a/pkg/bench/get.go +++ b/pkg/bench/get.go @@ -113,7 +113,7 @@ func (g *Get) Prepare(ctx context.Context) error { return (fmt.Errorf("no objects found for bucket %s", g.Bucket)) } done() - g.Collector = NewCollector() + g.addCollector() return nil } @@ -141,7 +141,6 @@ func (g *Get) Prepare(ctx context.Context) error { var wg sync.WaitGroup wg.Add(g.Concurrency) - g.addCollector() obj := make(chan struct{}, g.CreateObjects) for i := 0; i < g.CreateObjects; i++ { diff --git a/pkg/bench/list.go b/pkg/bench/list.go index 8806439c..615b4c4c 100644 --- a/pkg/bench/list.go +++ b/pkg/bench/list.go @@ -34,8 +34,7 @@ import ( // List benchmarks listing speed. type List struct { Common - Collector *Collector - objects []generator.Objects + objects []generator.Objects CreateObjects int Versions int diff --git a/pkg/bench/mixed.go b/pkg/bench/mixed.go index af84feeb..27a7a56a 100644 --- a/pkg/bench/mixed.go +++ b/pkg/bench/mixed.go @@ -35,8 +35,7 @@ import ( // Mixed benchmarks mixed operations all inclusive. type Mixed struct { Common - Collector *Collector - Dist *MixedDistribution + Dist *MixedDistribution GetOpts minio.GetObjectOptions StatOpts minio.StatObjectOptions diff --git a/pkg/bench/select.go b/pkg/bench/select.go index 28bed1dd..d42457ea 100644 --- a/pkg/bench/select.go +++ b/pkg/bench/select.go @@ -34,7 +34,6 @@ import ( // Select benchmarks download speed. type Select struct { Common - Collector *Collector // Default Select options. SelectOpts minio.SelectObjectOptions