syntax = "proto3";

package greeter;
option go_package = ".;greeter";

service Greeter {
  // Unary RPC
  rpc SayHelloUN (HelloRequest) returns (HelloResponse) {}
  // Server streaming RPC
  rpc SayHelloSS (HelloRequest) returns (stream HelloResponse) {}
  // Client streaming RPC
  rpc SayHelloCS (stream HelloRequest) returns (HelloResponse) {}
  // Bi-directional streaming RPC
  rpc SayHelloBI (stream HelloRequest) returns (stream HelloResponse) {}
}

message HelloRequest {
  string name = 1;
}
message HelloResponse {
  string result = 1;
}

type Status struct {
    // The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code].
    Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
    // A developer-facing error message, which should be in English. Any
    // user-facing error message should be localized and sent in the
    // [google.rpc.Status.details][google.rpc.Status.details] field, or localized by the client.
    Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    // A list of messages that carry the error details.  There is a common set of
    // message types for APIs to use.
    Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields

}

const (
    OK Code = 0
    Canceled Code = 1
    Unknown Code = 2
    InvalidArgument Code = 3
    // 中略...
    DataLoss Code = 15
    Unauthenticated Code = 16
)

func (s *Status) WithDetails(details ...proto.Message) (*Status, error)

import (
    pb "kitauji/greeter"
    "google.golang.org/grpc/codes"
    "google.golang.org/grpc/status"
    // 他は記載省略
)

func (s *myServer) SayHelloUN(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {
    if req.GetName() == "" {
        return nil, status.Errorf(codes.InvalidArgument, "Name is blank")
    }   
    // 以下略

import (
    pb "kitauji/greeter"
    "google.golang.org/genproto/googleapis/rpc/errdetails"
    "google.golang.org/grpc/codes"
    "google.golang.org/grpc/status"
)

func (s *myServer) SayHelloUN(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {
    if req.GetName() == "" {
        st := status.New(codes.InvalidArgument, "Name is blank")
        details := &errdetails.BadRequest{
            FieldViolations: []*errdetails.BadRequest_FieldViolation{
                {Field: "Name", Description: "Name is required. Only alphanumeric characters are allowed"},
            },
        }
        st, _ = st.WithDetails(details)
        return nil, st.Err()
    }
    // 以下略

    // Unary RPC の呼び出し
    resp, err := cli.SayHelloUN(context.Background(), req)
    if err != nil {
        // error から Status への変換
        st, ok := status.FromError(err)
        if !ok {
            // エラー処理...
            return
        }

        log.Printf("GRPC Error : Code [%d], Message [%s]", st.Code(), st.Message())

        // 詳細なエラー情報があれば処理する
        if len(st.Details()) > 0 {
            for _, detail := range st.Details() {
                // errdetails の型により処理を分ける
                switch d := detail.(type) {
                case *errdetails.BadRequest:
                    log.Printf("Details: BadRequest: %v", d)
                    // エラー処理...
                case *errdetails.DebugInfo:
                    log.Printf("Details: DebugInfo: %v", d)
                    // エラー処理...
                default:
                    log.Printf("Details: Unknown: %v", d)
                }
            }
        }
    }

func (s *myServer) SayHelloBI(stream pb.Greeter_SayHelloBIServer) error {
    for {
        req, err := stream.Recv()
        if err != nil {
            log.Printf("SayHelloBI: Recv() error : %v", err)
            return err
        }

        if req.GetName() == "" {
            // Name が空の場合はクライアントにエラーを通知したい。
            // ただし、このように単純にエラーを return すると接続が切れてしまう
            return status.Errorf(codes.InvalidArgument, "Name is blank")
        }

        // 以下、何かしら処理が続く
    }
}

service Greeter {
  // ...
  // Bidirectional streaming RPC
  rpc SayHelloBI (stream HelloRequest) returns (stream HelloResponse) {}
}

message HelloRequest {
  string name = 1;
}
message HelloResponse {
  string result = 1;
}

// フラットに持たせる
message StreamingHelloResponse {
  string result = 1;
  google.rpc.Status status = 2;
}

// oneof を使う
message StreamingHelloResponse {
  oneof response {
    string result = 1;
    google.rpc.Status status = 2;
  }
}

├── bin
│   └── protoc
├── include
│   └── google
│       ├── protobuf
│       │   ├── any.proto
│       │   ├── api.proto
│       │   └── などなど
│       └── rpc
│           └── status.proto  ← rpc ディレクトリを作ってここに置いた
└── readme.txt

// ダウンロードしたファイルをインポート
import "google/rpc/status.proto";

service Greeter {
  // レスポンスの型を HelloResponse から StreamingHelloResponse に変更
  rpc SayHelloBI (stream HelloRequest) returns (stream StreamingHelloResponse) {}
}

// 新しく追加する
message StreamingHelloResponse {
  oneof response {
    string result = 1;             // 成功時はこちらが返る
    google.rpc.Status status = 2;  // エラー時はこちらが返る  
  }
}

func (s *myServer) SayHelloBI(stream pb.Greeter_SayHelloBIServer) error {
    for {
        req, err := stream.Recv()
        if err != nil {
            log.Printf("SayHelloBI: Recv() error : %v", err)
            return err
        }

        log.Printf("SayHelloBI: Received: %v", req)

        if req.GetName() == "" {
            // Name が空の場合はクライアントにエラーを通知したい。

            // まず通常の Status を生成。
            st := status.New(codes.InvalidArgument, "Name is blank")

            // *.proto の StreamingHelloResponse 内で定義した Status を生成
            respStatus := &pb.StreamingHelloResponse_Status{Status: st.Proto()}

            // StreamingHelloResponse を生成して、クライアントに送信する
            resp := &pb.StreamingHelloResponse{Response: respStatus}
            stream.Send(resp)
        }

func SayHelloBIRecv(stream pb.Greeter_SayHelloBIClient) {
    // 中略

    resp, err := stream.Recv()
    if err != nil {
        // 受信失敗時の処理
    }

    // 受信したレスポンスに Status 情報(つまりエラー)が含まれているかチェック
    if st := resp.GetStatus(); st != nil {
        // あれば中身の Status を取り出して処理する
        s := status.FromProto(st)
        log.Printf("Status : Code [%d], Message [%s]", s.Code(), s.Message())

    }

    // 成功時の戻り値が入っていることをチェック
    // (Status が空なので入っているはずだが念のため)
    if resp.GetResult() != "" {
        // 成功時の処理
    }