Skip to content
Snippets Groups Projects
Commit ac477530 authored by xujianhai666's avatar xujianhai666
Browse files

add new client test

parent c7d140d6
No related branches found
No related tags found
No related merge requests found
...@@ -18,16 +18,18 @@ limitations under the License. ...@@ -18,16 +18,18 @@ limitations under the License.
package grpc package grpc
import ( import (
"context"
"reflect" "reflect"
"testing" "testing"
) )
import ( import (
"github.com/bmizerany/assert" "github.com/stretchr/testify/assert"
"google.golang.org/grpc" "google.golang.org/grpc"
) )
import ( import (
"github.com/apache/dubbo-go/common"
"github.com/apache/dubbo-go/protocol/grpc/internal" "github.com/apache/dubbo-go/protocol/grpc/internal"
) )
...@@ -40,3 +42,14 @@ func TestGetInvoker(t *testing.T) { ...@@ -40,3 +42,14 @@ func TestGetInvoker(t *testing.T) {
expected := reflect.TypeOf(internal.NewGreeterClient(nil)) expected := reflect.TypeOf(internal.NewGreeterClient(nil))
assert.Equal(t, i, expected) assert.Equal(t, i, expected)
} }
func TestNewClient(t *testing.T) {
go internal.InitGrpcServer()
defer internal.ShutdownGrpcServer()
var impl *internal.GrpcGreeterImpl
url, err := common.NewURL(context.Background(), "grpc://127.0.0.1:20000/GrpcGreeterImpl?accesslog=&anyhost=true&app.version=0.0.1&application=BDTService&async=false&bean.name=GrpcGreeterImpl&category=providers&cluster=failover&dubbo=dubbo-provider-golang-2.6.0&environment=dev&execute.limit=&execute.limit.rejected.handler=&generic=false&group=&interface=io.grpc.examples.helloworld.GreeterGrpc%24IGreeter&ip=192.168.1.106&loadbalance=random&methods.SayHello.loadbalance=random&methods.SayHello.retries=1&methods.SayHello.tps.limit.interval=&methods.SayHello.tps.limit.rate=&methods.SayHello.tps.limit.strategy=&methods.SayHello.weight=0&module=dubbogo+say-hello+client&name=BDTService&organization=ikurento.com&owner=ZX&pid=49427&reference.filter=cshutdown&registry.role=3&remote.timestamp=1576923717&retries=&service.filter=echo%2Ctoken%2Caccesslog%2Ctps%2Cexecute%2Cpshutdown&side=provider&timestamp=1576923740&tps.limit.interval=&tps.limit.rate=&tps.limit.rejected.handler=&tps.limit.strategy=&tps.limiter=&version=&warmup=100!")
assert.Nil(t, err)
cli := NewClient(impl, url)
assert.NotNil(t, cli)
}
...@@ -35,14 +35,14 @@ import ( ...@@ -35,14 +35,14 @@ import (
// userd grpc-dubbo biz service // userd grpc-dubbo biz service
func addService() { func addService() {
config.SetProviderService(NewGreeterProvider()) config.SetProviderService(newGreeterProvider())
} }
type greeterProvider struct { type greeterProvider struct {
*greeterProviderBase *greeterProviderBase
} }
func NewGreeterProvider() *greeterProvider { func newGreeterProvider() *greeterProvider {
return &greeterProvider{ return &greeterProvider{
greeterProviderBase: &greeterProviderBase{}, greeterProviderBase: &greeterProviderBase{},
} }
......
...@@ -49,7 +49,6 @@ func NewGRPCProtocol() *GrpcProtocol { ...@@ -49,7 +49,6 @@ func NewGRPCProtocol() *GrpcProtocol {
} }
} }
// 缺少一个 type 信息, 无法进行binding
func (gp *GrpcProtocol) Export(invoker protocol.Invoker) protocol.Exporter { func (gp *GrpcProtocol) Export(invoker protocol.Invoker) protocol.Exporter {
url := invoker.GetUrl() url := invoker.GetUrl()
serviceKey := url.ServiceKey() serviceKey := url.ServiceKey()
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment