Skip to content

Commit 5622a8d

Browse files
author
dapeng
committed
example: example/grpc update
1 parent a095015 commit 5622a8d

File tree

5 files changed

+34
-30
lines changed

5 files changed

+34
-30
lines changed

example/grpc/Makefile

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,17 +2,13 @@
22
.PHONY: client
33

44
pb:
5-
make dep
5+
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
6+
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@latest
67
protoc --go_out=. --go_opt=paths=source_relative \
78
--go-grpc_out=. --go-grpc_opt=paths=source_relative \
89
proto/hello.proto
910

1011

11-
dep:
12-
go get google.golang.org/protobuf/cmd/protoc-gen-go
13-
go install google.golang.org/protobuf/cmd/protoc-gen-go
14-
go get google.golang.org/grpc/cmd/protoc-gen-go-grpc
15-
go install google.golang.org/grpc/cmd/protoc-gen-go-grpc
1612

1713
server:
1814
go run server/main.go

example/grpc/client/main.go

Lines changed: 16 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -27,20 +27,21 @@ func (c *helloClient) Stub(conn *grpc.ClientConn) {
2727
}
2828

2929
func main() {
30-
gone.Prepare(func(cemetery gone.Cemetery) error {
31-
_ = goner.BasePriest(cemetery)
32-
_ = goner.GrpcClientPriest(cemetery)
30+
gone.
31+
Prepare(func(cemetery gone.Cemetery) error {
32+
_ = goner.GrpcClientPriest(cemetery)
3333

34-
cemetery.Bury(&helloClient{})
35-
return nil
36-
}).AfterStart(func(in struct {
37-
hello *helloClient `gone:"*"`
38-
}) {
39-
say, err := in.hello.Say(context.Background(), &proto.SayRequest{Name: "gone"})
40-
if err != nil {
41-
log.Printf("er:%v", err)
42-
return
43-
}
44-
log.Printf("say result: %s", say.Message)
45-
}).Run()
34+
cemetery.Bury(&helloClient{})
35+
return nil
36+
}).
37+
Run(func(in struct {
38+
hello *helloClient `gone:"*"`
39+
}) {
40+
say, err := in.hello.Say(context.Background(), &proto.SayRequest{Name: "gone"})
41+
if err != nil {
42+
log.Printf("er:%v", err)
43+
return
44+
}
45+
log.Printf("say result: %s", say.Message)
46+
})
4647
}

example/grpc/server/main.go

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,13 @@ func (s *server) RegisterGrpcServer(server *grpc.Server) {
2626
}
2727

2828
func main() {
29-
gone.Prepare(func(cemetery gone.Cemetery) error {
30-
_ = goner.BasePriest(cemetery)
31-
_ = cmux.Priest(cemetery)
32-
_ = goner.GrpcServerPriest(cemetery)
29+
gone.
30+
Prepare(func(cemetery gone.Cemetery) error {
31+
_ = cmux.Priest(cemetery)
32+
_ = goner.GrpcServerPriest(cemetery)
3333

34-
cemetery.Bury(&server{})
35-
return nil
36-
}).Serve()
34+
cemetery.Bury(&server{})
35+
return nil
36+
}).
37+
Serve()
3738
}

goner/logrus/priest.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,10 @@ import (
99
func Priest(cemetery gone.Cemetery) error {
1010
t := cemetery.GetTomById(gone.IdGoneLogger)
1111
if t != nil && t.GetGoner().(gone.Logger) != gone.GetSimpleLogger() {
12-
t.GetGoner().(gone.Logger).Warn("logger is loaded, logrus logger not used")
12+
_, ok := t.GetGoner().(*logger)
13+
if !ok {
14+
t.GetGoner().(gone.Logger).Warn("logger is loaded, logrus logger not used")
15+
}
1316
return nil
1417
}
1518
_ = config.Priest(cemetery)

goner/zap/priest.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,10 @@ import (
99
func Priest(cemetery gone.Cemetery) error {
1010
t := cemetery.GetTomById(gone.IdGoneLogger)
1111
if t != nil && t.GetGoner().(gone.Logger) != gone.GetSimpleLogger() {
12-
t.GetGoner().(gone.Logger).Warn("logger is loaded, zap logger not used")
12+
_, ok := t.GetGoner().(*sugar)
13+
if !ok {
14+
t.GetGoner().(gone.Logger).Warn("logger is loaded, zap logger not used")
15+
}
1316
return nil
1417
}
1518

0 commit comments

Comments
 (0)