GRPC Apis for Corresponding HTTP APIs

README.md

@@ -59,6 +59,14 @@ gRPC API:
 * `/grpc.health.v1.Health/Check` health checking
 * `/grpc.EchoService/Echo` echos the received content
 * `/grpc.VersionService/Version` returns podinfo version and Git commit hash
+* `/grpc.DelayService/Delay` returns a successful response after the given seconds in the body of gRPC request
+* `/grpc.EnvService/Env` returns environment variables as a JSON array
+* `/grpc.HeaderService/Header` returns the headers present in the gRPC request. Any custom header can also be given as a part of request and that can be returned using this API
+* `/grpc.InfoService/Info` returns the runtime information
+* `/grpc.PanicService/Panic` crashes the process with gRPC status code as '1 CANCELLED'
+* `/grpc.StatusService/Status` returns the gRPC Status code given in the request body
+* `/grpc.TokenService/TokenGenerate` issues a JWT token valid for one minute
+* `/grpc.TokenService/TokenValidate` validates the JWT token
 
 Web UI:
 

cmd/podinfo/main.go

@@ -139,7 +139,7 @@ func main() {
  if grpcCfg.Port > 0 {
  grpcSrv, _ := grpc.NewServer(&grpcCfg, logger)
  //grpcinfoSrv, _ := grpc.NewInfoServer(&grpcCfg)
- 
+
  grpcServer = grpcSrv.ListenAndServe()
  }
 

pkg/api/grpc/delay.go

@@ -0,0 +1,21 @@
+package grpc
+
+import (
+ "context"
+ "time"
+
+ pb "github.com/stefanprodan/podinfo/pkg/api/grpc/delay"
+ "go.uber.org/zap"
+)
+
+type DelayServer struct {
+ pb.UnimplementedDelayServiceServer
+ config *Config
+ logger *zap.Logger
+}
+
+func (s *DelayServer) Delay(ctx context.Context, delayInput *pb.DelayRequest) (*pb.DelayResponse, error) {
+
+ time.Sleep(time.Duration(delayInput.Seconds) * time.Second)
+ return &pb.DelayResponse{Message: delayInput.Seconds}, nil
+}

pkg/api/grpc/delay/delay.proto

@@ -0,0 +1,17 @@
+syntax = "proto3";
+
+option go_package = "./delay";
+
+package delay;
+
+message DelayRequest {
+ int64 seconds = 1;
+}
+
+message DelayResponse {
+ int64 message = 1;
+}
+
+service DelayService {
+ rpc Delay (DelayRequest) returns (DelayResponse) {}
+}