GRPC Apis for Corresponding HTTP APIs

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) {}
+}