From 255fbc4e876b35a4e376b8a1358431ee4bcd8420 Mon Sep 17 00:00:00 2001
From: "382673304@qq.com" <382673304@qq.com>
Date: Tue, 13 Oct 2020 19:22:18 +0800
Subject: [PATCH] chore: bugs
---
protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go | 2 +-
registry/consul/registry.go | 3 ---
2 files changed, 1 insertion(+), 4 deletions(-)
diff --git a/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go b/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
index ae9cc72d0..b34ecfaa9 100644
--- a/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
+++ b/protocol/grpc/protoc-gen-dubbo/plugin/dubbo/dubbo.go
@@ -240,7 +240,7 @@ func (g *dubboGrpc) generateClientSignature(servName string, method *pb.MethodDe
}
respName := "out *" + g.typeName(method.GetOutputType())
if method.GetServerStreaming() || method.GetClientStreaming() {
- respName = "out * "+ servName + "_" + generator.CamelCase(origMethName) + "Client"
+ respName = servName + "_" + generator.CamelCase(origMethName) + "Client"
}
return fmt.Sprintf("%s func(ctx %s.Context%s, %s) error", methName, contextPkg, reqArg, respName)
}
diff --git a/registry/consul/registry.go b/registry/consul/registry.go
index 78caa5a18..b92e335fd 100644
--- a/registry/consul/registry.go
+++ b/registry/consul/registry.go
@@ -56,9 +56,6 @@ type consulRegistry struct {
// Done field represents whether
// consul registry is closed.
done chan struct{}
-
- // time wait when destroy
- timeOut time.Duration
}
func newConsulRegistry(url *common.URL) (registry.Registry, error) {
--
GitLab