code: func main() {
  
  	stream := health.NewStream().AddSink(&health.WriterSink{os.Stdout})
  	stream.Event("wat")
  	cleanKeyspace()
  
  	queues := []string{"myqueue", "myqueue2", "myqueue3", "myqueue4", "myqueue5"}
  	numJobs := 100000 / len(queues)
  
  	job := stream.NewJob("enqueue_all")
  	for _, q := range queues {
  		enqueueJobs(q, numJobs)
  	}
  	job.Complete(health.Success)
  
  	goworker.Register("MyClass", myJob)
  
  	go monitor()
  
  	// Blocks until process is told to exit via unix signal
  	goworker.Work()
  }
docs: // go run *.go -queues="myqueue,myqueue2,myqueue3,myqueue4,myqueue5" -namespace="bench_test:" -concurrency=50 -use-nuber