lorem-grpc trasport layer

transport.go

package lorem_grpc

import (
	"golang.org/x/net/context"
	grpctransport "github.com/go-kit/kit/transport/grpc"
	"github.com/ru-rocker/gokit-playground/lorem-grpc/pb"
)

type grpcServer struct {
	lorem grpctransport.Handler
}

// implement LoremServer Interface in lorem.pb.go
func (s *grpcServer) Lorem(ctx context.Context, r *pb.LoremRequest) (*pb.LoremResponse, error) {
	_, resp, err := s.lorem.ServeGRPC(ctx, r)
	if err != nil {
		return nil, err
	}
	return resp.(*pb.LoremResponse), nil
}

// create new grpc server
func NewGRPCServer(ctx context.Context, endpoint Endpoints) pb.LoremServer {
	return &grpcServer{
		lorem: grpctransport.NewServer(
			ctx,
			endpoint.LoremEndpoint,
			DecodeGRPCLoremRequest,
			EncodeGRPCLoremResponse,
		),
	}
}