Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(49)

Unified Diff: appengine/logdog/coordinator/endpoints/services/loadStream.go

Issue 1910923002: LogDog: Add project namespace to service endpoint. (Closed) Base URL: https://github.com/luci/luci-go@logdog-project-coordinator-backend
Patch Set: Comments. Created 4 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: appengine/logdog/coordinator/endpoints/services/loadStream.go
diff --git a/appengine/logdog/coordinator/endpoints/services/loadStream.go b/appengine/logdog/coordinator/endpoints/services/loadStream.go
index 01b9b337edfc73e7f34430c35a2901f7a91b284e..be9f02ea7dda5457590df2d86e8e227503c09ebf 100644
--- a/appengine/logdog/coordinator/endpoints/services/loadStream.go
+++ b/appengine/logdog/coordinator/endpoints/services/loadStream.go
@@ -19,20 +19,22 @@ import (
// LoadStream loads the log stream state.
func (s *server) LoadStream(c context.Context, req *logdog.LoadStreamRequest) (*logdog.LoadStreamResponse, error) {
+ log.Fields{
+ "project": req.Project,
+ "path": req.Path,
+ }.Infof(c, "Loading log stream state.")
+
path := types.StreamPath(req.Path)
if err := path.Validate(); err != nil {
return nil, grpcutil.Errf(codes.InvalidArgument, "Invalid path (%s): %s", path, err)
}
- log.Fields{
- "path": path,
- }.Infof(c, "Loading log stream state.")
ls := coordinator.LogStreamFromPath(path)
switch err := ds.Get(c).Get(ls); err {
case nil:
// The log stream loaded successfully.
resp := logdog.LoadStreamResponse{
- State: loadLogStreamState(ls),
+ State: loadLogStreamState(coordinator.Project(c), ls),
}
if req.Desc {
resp.Desc = ls.Descriptor

Powered by Google App Engine
This is Rietveld 408576698