рентгеновская установка с буйволом

Я пытаюсь настроить buffalo для отправки данных в AWS X-Ray. Я новичок в buffalo/go, и я полностью потерялся в документах...

Мои действия.go

package actions

import (
    "fmt"
    "github.com/gobuffalo/buffalo"
    "github.com/gobuffalo/envy"
    "github.com/aws/aws-xray-sdk-go/xray"
    contenttype "github.com/gobuffalo/mw-contenttype"
    "github.com/gobuffalo/x/sessions"
    "github.com/rs/cors"
)

var ENV = envy.Get("GO_ENV", "development")
var app *buffalo.App

func App() *buffalo.App {
    if app == nil {
        app = buffalo.New(buffalo.Options{
            Env:          ENV,
            SessionStore: sessions.Null{},
            PreWares: []buffalo.PreWare{
                cors.Default().Handler,
            },
            SessionName: "__session",
        })

        app.Use(contenttype.Set("application/json"))
        app.Use(XRayStart)
        app.GET("/", HomeHandler)
    }
    return app
}

// XRayStart starts xray
func XRayStart(next buffalo.Handler) buffalo.Handler {
    return func(c buffalo.Context) error {
        fmt.Println("1")
        h := xray.Handler(xray.NewFixedSegmentNamer("WordAPI"), buffalo.WrapBuffaloHandler(next))
        fmt.Println(h)
        err := next(c)
        return err
    }
}

func init() {
    fmt.Println("init")
    xray.Configure(xray.Config{
        DaemonAddr:     "127.0.0.1:2000", // default
        ServiceVersion: "1.2.3",
    })
}

Когда я скручиваюсь, я получаю правильный ответ от HomeHandler, и журналы внутри промежуточного программного обеспечения печатаются (h не равен нулю). Инит тоже называется правильно. На стороне демона я вообще ничего не вижу :(

В официальных документах есть этот пример кода

func main() {
  http.Handle("/", xray.Handler(xray.NewFixedSegmentNamer("myApp"), http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    w.Write([]byte("Hello!"))
  })))
  http.ListenAndServe(":8000", nil)
}

и я полагаю, что мой порт неверен ..

Любое предложение о том, как действовать?

Благодарность


person Giuliano Zorzi    schedule 19.09.2019    source источник


Ответы (1)


h := xray.Handler(xray.NewFixedSegmentNamer("WordAPI"), buffalo.WrapBuffaloHandler(next))

Строка создает обработчик xray http, но никогда его не использовала. Вы можете использовать Buffalo WrapHandler(), чтобы снова превратить его в обработчик buffalo и прослушать входящий запрос. Итак, это будет работать:

app.GET("/", 
    buffalo.WrapHandler(xray.Handler(xray.NewFixedSegmentNamer("WordAPI"), 
        buffalo.WrapBuffaloHandler(HomeHandler))))
person Shengxin Li    schedule 10.10.2019