Skip to content

Commit 418f0e3

Browse files
authored
feat: add a new echo gRPC service (#22)
1 parent 7826092 commit 418f0e3

File tree

4 files changed

+275
-0
lines changed

4 files changed

+275
-0
lines changed

main.go

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/helloworld.proto
2020
//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/import.proto
2121
//go:generate protoc --include_imports --descriptor_set_out=proto.pb --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/src.proto
22+
//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative proto/echo.proto
2223

2324
// Package main implements a server for Greeter service.
2425
package main
@@ -71,6 +72,7 @@ type server struct {
7172
// Embed the unimplemented server
7273
pb.UnimplementedGreeterServer
7374
pb.UnimplementedTestImportServer
75+
pb.UnsafeEchoServer
7476
}
7577

7678
// SayHello implements helloworld.GreeterServer
@@ -189,6 +191,14 @@ func (s *server) SayHelloBidirectionalStream(stream pb.Greeter_SayHelloBidirecti
189191
}
190192
}
191193

194+
// Hi implements echo.Echo/Hi
195+
func (s *server) Hi(ctx context.Context, in *pb.EchoMsg) (*pb.EchoMsg, error) {
196+
msg := "Hi " + in.Msg
197+
return &pb.EchoMsg{
198+
Msg: msg,
199+
}, nil
200+
}
201+
192202
func (s *server) Run(ctx context.Context, in *pb.Request) (*pb.Response, error) {
193203
return &pb.Response{Body: in.User.Name + " " + in.Body}, nil
194204
}
@@ -205,6 +215,7 @@ func main() {
205215
reflection.Register(s)
206216
pb.RegisterGreeterServer(s, &server{})
207217
pb.RegisterTestImportServer(s, &server{})
218+
pb.RegisterEchoServer(s, &server{})
208219
if err := s.Serve(lis); err != nil {
209220
log.Fatalf("failed to serve: %v", err)
210221
}
@@ -223,6 +234,7 @@ func main() {
223234
s := grpc.NewServer(grpc.Creds(c))
224235
reflection.Register(s)
225236
pb.RegisterGreeterServer(s, &server{})
237+
pb.RegisterEchoServer(s, &server{})
226238
if err := s.Serve(lis); err != nil {
227239
log.Fatalf("failed to serve: %v", err)
228240
}

proto/echo.pb.go

Lines changed: 146 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/echo.proto

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
syntax = "proto3";
2+
3+
package echo;
4+
option go_package="./proto";
5+
6+
service Echo {
7+
rpc Hi (EchoMsg) returns (EchoMsg);
8+
}
9+
10+
message EchoMsg {
11+
string msg = 1;
12+
}

proto/echo_grpc.pb.go

Lines changed: 105 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)