LogDog: Add project support to Storage.

server/logdog/storage/archive/storage.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 archive implements a storage.Storage instance that retrieves logs
 // from a Google Storage archive.
 //
 // This is a special implementation of storage.Storage, and does not fully
 // conform to the API expecations. Namely:
 //      - It is read-only. Mutation methods will return storage.ErrReadOnly.
 //      - Storage methods ignore the supplied Path argument, instead opting for
 //        the archive configured in its Options.
 package archive
 
 import (
         "bytes"
         "fmt"
         "io"
         "io/ioutil"
         "sort"
         "sync"
 
         "golang.org/x/net/context"
 
         "github.com/golang/protobuf/proto"
+        "github.com/luci/luci-go/common/config"
         "github.com/luci/luci-go/common/gcloud/gs"
         "github.com/luci/luci-go/common/iotools"
         "github.com/luci/luci-go/common/logdog/types"
         log "github.com/luci/luci-go/common/logging"
         "github.com/luci/luci-go/common/proto/logdog/logpb"
         "github.com/luci/luci-go/common/recordio"
         "github.com/luci/luci-go/server/logdog/storage"
 )
 
 const (
         // maxStreamRecordSize is the maximum record size we're willing to read from
         // our archived log stream. This will help prevent out-of-memory errors if the
         // arhived log stream is malicious or corrupt.
         maxStreamRecordSize = 16 * 1024 * 1024
 )
 
 // Options is the set of configuration options for this Storage instance.
 //
 // Unlike other Storage instances, this is bound to a single archived stream.
-// Path parameters in requests will be ignored in favor of the Google Storage
-// URLs.
+// Project and Path parameters in requests will be ignored in favor of the
+// Google Storage URLs.
 type Options struct {
         // IndexURL is the Google Storage URL for the stream's index.
         IndexURL string
         // StreamURL is the Google Storage URL for the stream's entries.
         StreamURL string
 
         // Client is the HTTP client to use for authentication.
         //
         // Closing this Storage instance does not close the underlying Client.
         Client gs.Client
@@ skipping 140 matching lines @@
                 if max > 0 {
                         max--
                         if max == 0 {
                                 break
                         }
                 }
         }
         return nil
 }
 
-func (s *storageImpl) Tail(path types.StreamPath) ([]byte, types.MessageIndex, error) {
+func (s *storageImpl) Tail(project config.ProjectName, path types.StreamPath) ([]byte, types.MessageIndex, error) {
         idx, err := s.getIndex()
         if err != nil {
                 return nil, 0, err
         }
 
         // Get the offset of the last record.
         if len(idx.Entries) == 0 {
                 return nil, 0, nil
         }
         lle := idx.Entries[len(idx.Entries)-1]
@@ skipping 156 matching lines @@
         ui := uint64(i)
         s := sort.Search(len(entries), func(i int) bool {
                 return entries[i].StreamIndex > ui
         })
 
         // The returned index is the one immediately after the index that we want. If
         // our search returned 0, the first index entry is > our search entry, and we
         // will return nil.
         return s - 1
 }