ミドルウェア

// ErrorLogger は、指定されたロガーを使用してエラーを記録するエンドポイントミドルウェアです。
// すべてのログエントリは、指定されたプレフィックスで始まります。
func ErrorLogger(l *log.Logger, prefix string) func (goa.Endpoint) goa.Endpoint {
    return func(e goa.Endpoint) goa.Endpoint {
        // Goa エンドポイント自体が関数です。
        return goa.Endpoint(func (ctx context.Context, req interface{}) (interface{}, error) {
            // オリジナルのエンドポイント関数を呼び出します。
            res, err := e(ctx, req)
            // 何かエラーがあれば記録する。
            if err != nil {
                l.Printf("%s: %s", prefix, err.Error())
            }
            // エンドポイントの結果を返します。
            return res, err
        })
    }
}

import (
    calcsvc "goa.design/examples/basic/gen/calc"
    calc "goa.design/examples/basic"
)

func main() {
    // ...
    var svc calcsvc.Service
    {
        svc = calc.NewCalc(logger)
    }

    var eps *calcsvc.Endpoints
    {
        eps = calcsvc.NewEndpoints(svc)

        // ErrorLoggerをすべてのエンドポイントに適用します。
        calcsvc.Use(ErrorLogger(logger, "calc"))

        // または、特定のエンドポイントにErrorLoggerを適用します。
        // eps.Add = ErrorLogger(logger, "add")(eps.Add)
    }
    // ...
}

// InitRequestID は、X-Request-Id ヘッダーの値を読み取り、存在する場合は
// それをリクエストコンテキストに書き込む HTTP サーバーミドルウェアです。
func InitRequestID() func(http.Handler) http.Handler {
    return func(h http.Handler) http.Handler {
        // A HTTP handler is a function.
        return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            req := r
            //  X-Request-Idヘッダーを取得して、リクエストコンテキストを初期化します。
            if id := r.Header.Get("X-Request-Id"); id != "" {
                ctx = context.WithValue(r.Context(), RequestIDKey, id)
                req = r.WithContext(ctx)
            }

            // 最初のハンドラを呼び出す。
            h.ServeHTTP(w, req)
        })
    }
}

func main() {
    // ...
    var mux goahttp.Muxer
    {
        mux = goahttp.NewMuxer()
    }

    var calcServer *calcsvcsvr.Server
    {
        calcServer = calcsvcsvr.New(calcEndpoints, mux, dec, enc, errorHandler(logger))
        // InitRequestID ミドルウェアをすべてのサーバーハンドラに適用します。
        calcServer.Use(InitRequestID())
    }

    // あるいは、ミドルウェアをすべてのリクエストに適用します。
    // var handler http.Handler = mux
    // handler = InitRequestID()(handler)
    // ... ここで、mux の代わりにハンドラを使用して HTTP サーバーを起動します。
}