Chromium Code Reviews| Index: milo/appengine/logdog/http.go |
| diff --git a/milo/appengine/logdog/http.go b/milo/appengine/logdog/http.go |
| index b75a8db69818a5ee60f2f0f695f2bfb69114990c..7298487649a6087b76d060bb4c460ddb03fc0620 100644 |
| --- a/milo/appengine/logdog/http.go |
| +++ b/milo/appengine/logdog/http.go |
| @@ -11,6 +11,8 @@ import ( |
| "github.com/julienschmidt/httprouter" |
| "github.com/luci/luci-go/common/config" |
| log "github.com/luci/luci-go/common/logging" |
| + "github.com/luci/luci-go/grpc/prpc" |
| + "github.com/luci/luci-go/logdog/client/coordinator" |
| "github.com/luci/luci-go/logdog/common/types" |
| "github.com/luci/luci-go/milo/appengine/settings" |
| "github.com/luci/luci-go/milo/common/miloerror" |
| @@ -53,15 +55,19 @@ func (s *AnnotationStream) Render(c context.Context, req *http.Request, p httpro |
| project: config.ProjectName(p.ByName("project")), |
| path: types.StreamPath(strings.Trim(p.ByName("path"), "/")), |
| host: req.FormValue("host"), |
| - |
| - logDogClient: http.Client{ |
| - Transport: t, |
| - }, |
| } |
| if err := as.normalize(); err != nil { |
| return nil, err |
| } |
| + // Setup our LogDog client. |
| + as.logDogClient = coordinator.NewClient(&prpc.Client{ |
|
martiniss
2016/09/22 03:40:39
why was this moved?
dnj
2016/09/22 16:00:05
Previously, "logDogClient" was an http.Client. Now
|
| + C: &http.Client{ |
| + Transport: t, |
| + }, |
| + Host: as.host, |
| + }) |
| + |
| // Load the Milo annotation protobuf from the annotation stream. |
| if err := as.load(c); err != nil { |
| return nil, err |