add pubsub

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>

grpc/go.mod

@@ -21,7 +21,7 @@ require (
 	go.unistack.org/micro-wrapper-recovery/v3 v3.8.3
 	go.unistack.org/micro-wrapper-requestid/v3 v3.8.1
 	go.unistack.org/micro-wrapper-validator/v3 v3.1.2
-	go.unistack.org/micro/v3 v3.9.14
+	go.unistack.org/micro/v3 v3.9.15
 	google.golang.org/protobuf v1.28.1
 	modernc.org/sqlite v1.19.5
 

grpc/go.sum

@@ -477,8 +477,9 @@ go.unistack.org/micro/v3 v3.8.21/go.mod h1:aBOCQ6SkAwKMRI7Q1CIsQA2S88ibyJfweJZlT
 go.unistack.org/micro/v3 v3.9.10/go.mod h1:LrBm9Fsf4MbY8DlUbdwRTYJosMkN8wrtOQHoYBlMkz8=
 go.unistack.org/micro/v3 v3.9.11/go.mod h1:LrBm9Fsf4MbY8DlUbdwRTYJosMkN8wrtOQHoYBlMkz8=
 go.unistack.org/micro/v3 v3.9.13/go.mod h1:gI4RkJKHLPW7KV6h4+ZBOZD997MRvFRXMPQIHpozikI=
-go.unistack.org/micro/v3 v3.9.14 h1:KTH3mrAMALFLAzH0fLJpaVmKjEa0VlHMRBJBUCKD91g=
 go.unistack.org/micro/v3 v3.9.14/go.mod h1:gI4RkJKHLPW7KV6h4+ZBOZD997MRvFRXMPQIHpozikI=
+go.unistack.org/micro/v3 v3.9.15 h1:Mv1/0jsySwIvm9+IvXTYj/X4bJCNChbwtf2ZV2ZDbk8=
+go.unistack.org/micro/v3 v3.9.15/go.mod h1:gI4RkJKHLPW7KV6h4+ZBOZD997MRvFRXMPQIHpozikI=
 golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=

grpc/main.go

@@ -186,7 +186,7 @@ func main() {
 			loggerwrapper.WithLogger(logger.DefaultLogger),
 			loggerwrapper.WithLevel(logger.InfoLevel),
 		)),
-		server.WrapHandler(meterwrapper.NewHandlerWrapper(
+		server.WrapHandler(meterwrapper.NewServerHandlerWrapper(
 			meterwrapper.ServiceName(svc.Server().Options().Name),
 			meterwrapper.ServiceVersion(svc.Server().Options().Version),
 			meterwrapper.ServiceID(svc.Server().Options().ID),