update go.mod

Author: zhanglifang@chinatelecom.cn

.gitignore

@@ -1,2 +1,3 @@
 /.idea
-/vendor
+/vendor
+go.sum

cmd/benchmark/connect/server.go

@@ -84,7 +84,7 @@ loop:
 				defer srv.wg.Done()
 				_, err := srv.connect(strconv.Itoa(i))
 				if err != nil {
-					log.Println("connect error:", err)
+					log.Println("connect error:", err.Error())
 					return
 				}
 			}(i)

cmd/benchmark/publish/command.go

@@ -41,7 +41,7 @@ func (cmd *Command) ParseFlags(args ...string) (Options, error) {
 	fs.IntVar(&options.Qos, "qos", 1, "qos")
 	fs.StringVar(&options.Topic, "topic", "topic_name", "topic name")
 	fs.IntVar(&options.ConnectionInterval, "ci", 100, "connection interval (ms)")
-	fs.IntVar(&options.PublishInterval, "i", 100, "publishing interval (ms)")
+	fs.IntVar(&options.PublishInterval, "i", 1000, "publishing interval (ms)")
 	fs.IntVar(&options.Count, "c", 1000, "number of clients")
 	fs.IntVar(&options.Size, "s", 256, "payload size (bytes)")
 	fs.IntVar(&options.SubCount, "sub", 0, "number of clients which subscribe topic #")

cmd/benchmark/publish/server.go

@@ -135,7 +135,7 @@ loop:
 				defer srv.wg.Done()
 				c, err := srv.connect(strconv.Itoa(i))
 				if err != nil {
-					log.Println("connect error:", err)
+					log.Println("connect error:", err.Error())
 					return
 				}
 				srv.publish(ctx, c)

go.mod

@@ -11,6 +11,7 @@ require (
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.1 // indirect
 	github.com/ugorji/go/codec v0.0.0-20181209151446-772ced7fd4c2 // indirect
+	golang.org/x/net v0.0.0-20190813141303-74dc4d7220e7 // indirect
 	gopkg.in/go-playground/validator.v8 v8.18.2 // indirect
 	gopkg.in/yaml.v2 v2.2.2
 )