Skip to content

Commit

Permalink
fix: 3.0 triple/grpc provider generated reference function by proto-g…
Browse files Browse the repository at this point in the history
…en-dubbo (apache#128)
  • Loading branch information
LaurenceLiZhixin committed Jun 11, 2021
1 parent 1452f49 commit f515e3e
Show file tree
Hide file tree
Showing 99 changed files with 76 additions and 4,187 deletions.
15 changes: 0 additions & 15 deletions .run/general/general-grpc-unary-go-client.run.xml

This file was deleted.

15 changes: 0 additions & 15 deletions .run/general/general-grpc-unary-go-server.run.xml

This file was deleted.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Expand Up @@ -16,7 +16,7 @@ registries:

# reference config
references:
"GreeterProvider":
"greeterImpl":
registry: "demoZk"
protocol: "tri"
interface: "protobuf.Greeter"
Expand Up @@ -76,8 +76,4 @@ func (s *GreeterProvider) SayHello(ctx context.Context, in *dubbo3.HelloRequest)
fmt.Println("get triple header tri-req-id = ", ctx.Value(tripleConstant.TripleCtxKey(tripleConstant.TripleRequestID)))
fmt.Println("get triple header tri-service-version = ", ctx.Value(tripleConstant.TripleCtxKey(tripleConstant.TripleServiceVersion)))
return &dubbo3.User{Name: "Hello " + in.Name, Id: "12345", Age: 21}, nil
}

func (g *GreeterProvider) Reference() string {
return "greeterImpl"
}
}
8 changes: 4 additions & 4 deletions general/dubbo3/pb/dubbogo-java/go-client/cmd/client.go
Expand Up @@ -20,7 +20,6 @@ package main
import (
"context"
"fmt"

"time"
)

Expand All @@ -38,11 +37,10 @@ import (
)

import (
"github.com/apache/dubbo-go-samples/general/dubbo3/pb/dubbogo-java/go-client/pkg"
pb "github.com/apache/dubbo-go-samples/general/dubbo3/pb/dubbogo-java/protobuf"
)

var grpcGreeterImpl = new(pkg.GreeterProvider)
var grpcGreeterImpl = new(pb.GreeterClientImpl)

func init() {
config.SetConsumerService(grpcGreeterImpl)
Expand All @@ -58,10 +56,12 @@ func main() {
Name: "laurence",
}

reply := &pb.User{}

ctx := context.Background()
ctx = context.WithValue(ctx, "tri-req-id", "test_value_XXXXXXXX")

reply, err := grpcGreeterImpl.SayHello(ctx, req)
err := grpcGreeterImpl.SayHello(ctx, req, reply)
if err != nil {
panic(err)
}
Expand Down
2 changes: 1 addition & 1 deletion general/dubbo3/pb/dubbogo-java/go-client/conf/client.yml
Expand Up @@ -25,7 +25,7 @@ registries:

# reference config
references:
"GreeterProvider":
"greeterImpl":
registry: "demoZk"
protocol: "tri"
interface: "com.apache.dubbo.sample.basic.IGreeter"
42 changes: 0 additions & 42 deletions general/dubbo3/pb/dubbogo-java/go-client/pkg/hello.go

This file was deleted.

2 changes: 1 addition & 1 deletion general/dubbo3/pb/dubbogo-java/go-server/conf/client.yml
Expand Up @@ -25,7 +25,7 @@ registries:

# reference config
references:
"GreeterProvider":
"greeterImpl":
registry: "demoZk"
protocol: "tri"
interface: "com.apache.dubbo.sample.basic.IGreeter"
2 changes: 1 addition & 1 deletion general/dubbo3/pb/dubbogo-java/go-server/conf/server.yml
Expand Up @@ -17,7 +17,7 @@ registries:

# service config
services:
"GreeterProvider":
"greeterImpl":
registry: "demoZK"
protocol: "tri"
interface: "com.apache.dubbo.sample.basic.IGreeter"
Expand Down
4 changes: 0 additions & 4 deletions general/dubbo3/pb/dubbogo-java/go-server/pkg/greeter.go
Expand Up @@ -43,7 +43,3 @@ func (s *GreeterProvider) SayHello(ctx context.Context, in *pb.HelloRequest) (*p
logger.Infof("Dubbo3 GreeterProvider get user name = %s\n", in.Name)
return &pb.User{Name: "Hello " + in.Name, Id: "12345", Age: 21}, nil
}

func (g *GreeterProvider) Reference() string {
return "GreeterProvider"
}
10 changes: 7 additions & 3 deletions general/dubbo3/pb/dubbogo-java/protobuf/helloworld.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

10 changes: 6 additions & 4 deletions general/grpc/go-client/cmd/client.go
Expand Up @@ -19,9 +19,6 @@ package main

import (
"context"
"github.com/apache/dubbo-go-samples/general/grpc/go-client/pkg"
"github.com/apache/dubbo-go-samples/general/grpc/protobuf"
"github.com/dubbogo/gost/log"
"time"
)

Expand All @@ -35,9 +32,14 @@ import (
_ "dubbo.apache.org/dubbo-go/v3/protocol/grpc"
_ "dubbo.apache.org/dubbo-go/v3/registry/protocol"
_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
"github.com/dubbogo/gost/log"
)

import(
"github.com/apache/dubbo-go-samples/general/grpc/protobuf"
)

var grpcGreeterImpl = new(pkg.GrpcGreeterImpl)
var grpcGreeterImpl = new(protobuf.GreeterClientImpl)

func init() {
config.SetConsumerService(grpcGreeterImpl)
Expand Down
2 changes: 1 addition & 1 deletion general/grpc/go-client/conf/client.yml
Expand Up @@ -25,7 +25,7 @@ registries:

# reference config
references:
"GrpcGreeterImpl":
"greeterImpl":
registry: "demoZk"
protocol: "grpc"
interface: "org.apache.dubbo.GreeterGrpc$IGreeter"
Expand Down
36 changes: 0 additions & 36 deletions general/grpc/go-client/pkg/hello.go

This file was deleted.

2 changes: 1 addition & 1 deletion general/grpc/go-server/conf/client.yml
Expand Up @@ -25,7 +25,7 @@ registries:

# reference config
references:
"GrpcGreeterImpl":
"greeterImpl":
registry: "demoZk"
protocol: "grpc"
interface: "org.apache.dubbo.GreeterGrpc$IGreeter"
Expand Down
2 changes: 1 addition & 1 deletion general/grpc/go-server/conf/server.yml
Expand Up @@ -17,7 +17,7 @@ registries:

# service config
services:
"GrpcGreeterImpl":
"greeterImpl":
registry: "zk"
protocol: "grpc"
interface: "org.apache.dubbo.GreeterGrpc$IGreeter"
Expand Down
3 changes: 0 additions & 3 deletions general/grpc/go-server/pkg/greeter.go
Expand Up @@ -38,6 +38,3 @@ func (g *GreeterProvider) SayHello(ctx context.Context, req *protobuf.HelloReque
return &protobuf.HelloReply{Message: "this is message from reply"}, nil
}

func (g *GreeterProvider) Reference() string {
return "GrpcGreeterImpl"
}
30 changes: 9 additions & 21 deletions general/grpc/go-server/tests/integration/main_test.go
Expand Up @@ -20,10 +20,12 @@
package integration

import (
"context"
"github.com/apache/dubbo-go-samples/general/grpc/protobuf"
"google.golang.org/grpc"
"os"
"testing"
"time"
)

import (
_ "dubbo.apache.org/dubbo-go/v3/cluster/cluster_impl"
_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance"
_ "dubbo.apache.org/dubbo-go/v3/common/proxy/proxy_factory"
Expand All @@ -35,30 +37,16 @@ import (
_ "dubbo.apache.org/dubbo-go/v3/registry/zookeeper"
)

import (
"os"
"testing"
"time"
import(
"github.com/apache/dubbo-go-samples/general/grpc/protobuf"
)

var grpcGreeterImpl = new(GrpcGreeterImpl)
var grpcGreeterImpl = new(protobuf.GreeterClientImpl)

func TestMain(m *testing.M) {
config.SetConsumerService(grpcGreeterImpl)
config.Load()
time.Sleep(3 * time.Second)

os.Exit(m.Run())
}

type GrpcGreeterImpl struct {
SayHello func(ctx context.Context, in *protobuf.HelloRequest, out *protobuf.HelloReply) error
}

func (u *GrpcGreeterImpl) Reference() string {
return "GrpcGreeterImpl"
}

func (u *GrpcGreeterImpl) GetDubboStub(cc *grpc.ClientConn) protobuf.GreeterClient {
return protobuf.NewGreeterClient(cc)
}
}

0 comments on commit f515e3e

Please sign in to comment.