LogDog: Add project namespacing to `logdog_cat`

common/logdog/coordinator/stream.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package coordinator
 
 import (
         "errors"
         "fmt"
         "time"
@@ skipping 101 matching lines @@
 
 // Get retrieves log stream entries from the Coordinator. The supplied
 // parameters shape which entries are requested and what information is
 // returned.
 func (s *Stream) Get(ctx context.Context, p *StreamGetParams) ([]*logpb.LogEntry, error) {
         if p == nil {
                 p = &StreamGetParams{}
         }
 
         req := p.r
+        req.Project = string(s.c.project)
         req.Path = string(s.path)
         if p.stateP != nil {
                 req.State = true
         }
 
         resp, err := s.c.C.Get(ctx, &req)
         if err != nil {
                 return nil, normalizeError(err)
         }
         if err := loadStatePointer(p.stateP, resp); err != nil {
                 return nil, err
         }
         return resp.Logs, nil
 }
 
 // Tail performs a tail call, returning the last log entry in the stream. If
 // stateP is not nil, the stream's state will be requested and loaded into the
 // variable.
 func (s *Stream) Tail(ctx context.Context, stateP *LogStream) (*logpb.LogEntry, error) {
         req := logdog.TailRequest{
-                Path: string(s.path),
+                Project: string(s.c.project),
+                Path:    string(s.path),
         }
         if stateP != nil {
                 req.State = true
         }
 
         resp, err := s.c.C.Tail(ctx, &req)
         if err != nil {
                 return nil, normalizeError(err)
         }
         if err := loadStatePointer(stateP, resp); err != nil {
@@ skipping 20 matching lines @@
         if resp.Desc == nil {
                 return errors.New("Requested descriptor was not returned")
         }
         if resp.State == nil {
                 return errors.New("Requested state was not returned")
         }
         ls := loadLogStream(resp.Desc.Path(), resp.State, resp.Desc)
         *stateP = *ls
         return nil
 }