生成されるgRPCサーバーとクライアントのコード

syntax = "proto3";

package calc;

service Calc {
    rpc Add (AddRequest) returns (AddResponse);
    rpc Multiply (MultiplyRequest) returns (MultiplyResponse);
}

message AddRequest {
    int64 a = 1;
    int64 b = 2;
}

message AddResponse {
    int64 result = 1;
}
// ...その他のメッセージ...

// Newは、calcサービスのエンドポイントを使用してサーバー構造体を
// インスタンス化します。
func New(e *calc.Endpoints, uh goagrpc.UnaryHandler) *Server {
    return &Server{
        AddH: NewAddHandler(e.Add, uh),
        MultiplyH: NewMultiplyHandler(e.Multiply, uh),
    }
}

// ServerはcalcサービスエンドポイントのgRPCハンドラーをリストします。
type Server struct {
    AddH      goagrpc.UnaryHandler
    MultiplyH goagrpc.UnaryHandler
    // ... プライベートフィールド ...
}

package main

import (
    "context"
    "log"
    "net"

    "google.golang.org/grpc"

    "github.com/<ユーザー名>/calc"
    gencalc "github.com/<ユーザー名>/calc/gen/calc"
    genpb "github.com/<ユーザー名>/calc/gen/grpc/calc/pb"
    gengrpc "github.com/<ユーザー名>/calc/gen/grpc/calc/server"
)

func main() {
    svc := calc.New()                        // サービスの実装
    endpoints := gencalc.NewEndpoints(svc)   // サービスエンドポイントの作成
    svr := grpc.NewServer(nil)               // gRPCサーバーの作成
    gensvr := gengrpc.New(endpoints, nil)    // サーバー実装の作成
    genpb.RegisterCalcServer(svr, genserver) // サーバーをgRPCに登録
    lis, _ := net.Listen("tcp", ":8080")     // gRPCサーバーリスナーの開始
    svr.Serve(lis)                           // gRPCサーバーの開始
}

// NewClientは、calcサービスのすべてのエンドポイントのgRPCクライアントを
// インスタンス化します。
func NewClient(cc *grpc.ClientConn, opts ...grpc.CallOption) *Client {
    return &Client{
        grpccli: calcpb.NewCalcClient(cc),
        opts:    opts,
    }
}

// Addは、calcサービスのaddサーバーにgRPCリクエストを行うエンドポイントを
// 返します。
func (c *Client) Add() goa.Endpoint

// Multiplyは、calcサービスのmultiplyサーバーにgRPCリクエストを行う
// エンドポイントを返します。
func (c *Client) Multiply() goa.Endpoint

package main

import (
    "context"
    "log"

    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
    
    gencalc "github.com/<ユーザー名>/calc/gen/calc"
    genclient "github.com/<ユーザー名>/calc/gen/grpc/calc/client"
)

func main() {
    // gRPC接続の作成
    conn, err := grpc.Dial("localhost:8080",
        grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    // gRPCクライアントの作成
    grpcClient := genclient.NewClient(conn)

    // エンドポイントクライアントの作成
    client := gencalc.NewClient(
        grpcClient.Add(),          // Addエンドポイント
        grpcClient.Multiply(),     // Multiplyエンドポイント
    )

    // サービスメソッドの呼び出し
    result, err := client.Add(context.Background(), &gencalc.AddPayload{A: 1, B: 2})
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("1 + 2 = %d", result)
}