如何使用go-kit发送请求报头作为响应报头

import (
    "net/http"
    "github.com/go-kit/kit/transport/http"
)

type MyRequestHeaders struct {
    Authorization string `json:"Authorization"`
}

type MyResponseHeaders struct {
    ContentType string `json:"Content-Type"`
}

func MyRequestHandler(ctx context.Context, req interface{}) (interface{}, error) {
    // 从上下文中获取请求报头
    headers, ok := ctx.Value(http.ContextKeyRequestHeaders).(http.Header)
    if !ok {
        return nil, errors.New("failed to get request headers")
    }

    // 从请求报头中获取需要发送的请求报头字段
    authorization := headers.Get("Authorization")

    // 创建响应报头
    responseHeaders := MyResponseHeaders{
        ContentType: "application/json",
    }

    // 发送请求报头作为响应报头
    return responseHeaders, nil
}

func MyRequestDecoder(_ context.Context, r *http.Request) (interface{}, error) {
    // 解码请求报文中的数据
    var requestHeaders MyRequestHeaders
    if err := json.NewDecoder(r.Body).Decode(&requestHeaders); err != nil {
        return nil, err
    }

    return requestHeaders, nil
}

func MyResponseEncoder(_ context.Context, w http.ResponseWriter, response interface{}) error {
    // 将响应报头写入响应报文
    responseHeaders, ok := response.(MyResponseHeaders)
    if !ok {
        return errors.New("invalid response type")
    }

    w.Header().Set("Content-Type", responseHeaders.ContentType)

    return nil
}

func main() {
    // 创建请求处理函数
    myHandler := http.NewServer(
        endpoint.Endpoint(MyRequestHandler),
        MyRequestDecoder,
        MyResponseEncoder,
    )

    // 启动 HTTP 服务
    http.Handle("/my-endpoint", myHandler)
    http.ListenAndServe(":8080", nil)
}