Merge pull request #24 from hellodudu/main

dashboard add nsq support

go.mod

@@ -8,6 +8,7 @@ require (
 	github.com/go-micro/plugins/v4/broker/kafka v1.2.0
 	github.com/go-micro/plugins/v4/broker/mqtt v1.2.0
 	github.com/go-micro/plugins/v4/broker/nats v1.2.0
+	github.com/go-micro/plugins/v4/broker/nsq v1.2.0
 	github.com/go-micro/plugins/v4/broker/rabbitmq v1.2.0
 	github.com/go-micro/plugins/v4/broker/redis v1.2.0
 	github.com/go-micro/plugins/v4/client/grpc v1.2.0
@@ -134,6 +135,7 @@ require (
 	github.com/nats-io/nats.go v1.20.0 // indirect
 	github.com/nats-io/nkeys v0.3.0 // indirect
 	github.com/nats-io/nuid v1.0.1 // indirect
+	github.com/nsqio/go-nsq v1.0.8 // indirect
 	github.com/nxadm/tail v1.4.8 // indirect
 	github.com/op/go-logging v0.0.0-20160315200505-970db520ece7 // indirect
 	github.com/opentracing/opentracing-go v1.2.1-0.20220228012449-10b1cf09e00b // indirect

go.sum

@@ -203,6 +203,8 @@ github.com/go-micro/plugins/v4/broker/mqtt v1.2.0 h1:tvKiwFhpMYEz9p0EmpD7Z0JYiBG
 github.com/go-micro/plugins/v4/broker/mqtt v1.2.0/go.mod h1:5UiWqSCi8q6gwayBAQMSxEuyAp4v7gvZYmDJHIuV2p0=
 github.com/go-micro/plugins/v4/broker/nats v1.2.0 h1:uI9ksw/YrG1dJWMHnG/1bqodqUr3OvsISyjWGjiBE6I=
 github.com/go-micro/plugins/v4/broker/nats v1.2.0/go.mod h1:HKZKcWPJQPCA2CA/WvDtko0aXz2U5xywZYzCgGn8hiY=
+github.com/go-micro/plugins/v4/broker/nsq v1.2.0 h1:ZOkfw0kyl8dhw8gBUbm55p8Hk7XYEcM+dQ2EhI9cpcs=
+github.com/go-micro/plugins/v4/broker/nsq v1.2.0/go.mod h1:JckVT6+rEWt/YI4Wa29vWd9iBZzCG8f0qACMvMmuPnI=
 github.com/go-micro/plugins/v4/broker/rabbitmq v1.2.0 h1:7LTGonUu0/1fpR4iZBm1EC7tV98nyS55yKLrnv08av0=
 github.com/go-micro/plugins/v4/broker/rabbitmq v1.2.0/go.mod h1:nPBTTlkdxUGd5zTcwOzeLc4hda1LGty87zBZTBjEmgM=
 github.com/go-micro/plugins/v4/broker/redis v1.2.0 h1:M5GmZ+sYpkjG+LYaKyO5kBHs5PQjlN6dg7KHPsurihU=
@@ -307,6 +309,7 @@ github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw
 github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
 github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
 github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
 github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/gomodule/redigo v1.8.9 h1:Sl3u+2BI/kk+VEatbj0scLdrFhjPmbxOc1myhDP41ws=
@@ -534,6 +537,8 @@ github.com/nats-io/nkeys v0.3.0/go.mod h1:gvUNGjVcM2IPr5rCsRsC6Wb3Hr2CQAm08dsxtV
 github.com/nats-io/nuid v1.0.1 h1:5iA8DT8V7q8WK2EScv2padNa/rTESc1KdnPw4TC2paw=
 github.com/nats-io/nuid v1.0.1/go.mod h1:19wcPz3Ph3q0Jbyiqsd0kePYG7A95tJPxeL+1OSON2c=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
+github.com/nsqio/go-nsq v1.0.8 h1:3L2F8tNLlwXXlp2slDUrUWSBn2O3nMh8R1/KEDFTHPk=
+github.com/nsqio/go-nsq v1.0.8/go.mod h1:vKq36oyeVXgsS5Q8YEO7WghqidAVXQlcFxzQbQTuDEY=
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
 github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=

plugins.go

@@ -4,6 +4,7 @@ import (
 	_ "github.com/go-micro/plugins/v4/broker/kafka"
 	_ "github.com/go-micro/plugins/v4/broker/mqtt"
 	_ "github.com/go-micro/plugins/v4/broker/nats"
+	_ "github.com/go-micro/plugins/v4/broker/nsq"
 	_ "github.com/go-micro/plugins/v4/broker/rabbitmq"
 	_ "github.com/go-micro/plugins/v4/broker/redis"