grpc example

Author: silentred

example/grpc/config.toml

@@ -0,0 +1,32 @@
+[app]
+runMode = "dev"
+name = "webapp"
+port = 18080
+
+logProvider = "file"
+logPath = "/tmp"
+logRotate = true
+logRotateType = "day"
+logLimit = "100MB"
+
+[session]
+enable = false
+provider = "file"
+
+[mysql_manager]
+ping = false
+
+[[mysql]]
+name="master"
+host="localhost"
+port=3306
+user="root"
+db="test"
+password=""
+read_only=false
+
+[redis]
+host="localhost"
+port= 6379
+db = 0
+ping = false

example/grpc/main.go

@@ -1,5 +1,35 @@
 package main
 
+import (
+	"github.com/silentred/toolkit/example/grpc/proto"
+	"github.com/silentred/toolkit/interceptor"
+	"github.com/silentred/toolkit/service"
+	"golang.org/x/net/context"
+	"google.golang.org/grpc"
+)
+
+type helloSvc struct{}
+
+// Hello implements helloworld.GreeterServer
+func (s *helloSvc) SayHello(ctx context.Context, in *proto.HelloReq) (*proto.HelloResp, error) {
+	// log ctx values)
+	return &proto.HelloResp{Message: "Hello " + in.Name}, nil
+}
+
 func main() {
+	app := service.NewGrpcApp(nil)
+	app.Initialize()
+
+	chain := interceptor.UnaryInterceptorChain(interceptor.NewRecovery(app.DefaultLogger()))
+	opt := grpc.UnaryInterceptor(chain)
+	s := grpc.NewServer(opt)
+
+	// register
+	hello := &helloSvc{}
+	proto.RegisterGreeterServer(s, hello)
+
+	// set service
+	app.SetServer(s)
 
+	app.ListenAndServe()
 }

example/grpc/proto/gen.sh

@@ -0,0 +1,2 @@
+#!/bin/bash
+protoc -I=. --gofast_out=plugins=grpc:. hello.proto