LogDog: Add project support to Storage.

server/logdog/storage/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 storage
 
 import (
         "errors"
         "time"
 
+        "github.com/luci/luci-go/common/config"
         "github.com/luci/luci-go/common/logdog/types"
 )
 
 var (
         // ErrExists returned if an attempt is made to overwrite an existing record.
         ErrExists = errors.New("storage: record exists")
 
         // ErrDoesNotExist returned if an attempt is made to read a record that
         // doesn't exist.
         ErrDoesNotExist = errors.New("storage: record does not exist")
@@ skipping 10 matching lines @@
 // instance.
 type Config struct {
         // MaxLogAge is the maximium amount of time that a log entry must be kept for.
         // The Storage instance is welcome to delete any log entries that exceed this
         // age.
         MaxLogAge time.Duration
 }
 
 // PutRequest describes adding a single storage record to BigTable.
 type PutRequest struct {
+        // Project is the project name of the stream.
+        Project config.ProjectName
         // Path is the stream path to retrieve.
         Path types.StreamPath
         // Index is the entry's stream index.
         Index types.MessageIndex
 
         // Values are contiguous sequential records to add to the storage. The first
         // index in values corresponds to Index.
         Values [][]byte
 }
 
 // GetRequest is a request to retrieve a series of LogEntry records.
 type GetRequest struct {
+        // Project is the project name of the stream.
+        Project config.ProjectName
         // Path is the stream path to retrieve.
         Path types.StreamPath
         // Index is the entry's stream index.
         Index types.MessageIndex
 
         // Limit is the maximum number of records to return before stopping iteration.
         // If zero, no maximum limit will be applied.
         //
         // The Storage instance may return fewer records than the supplied Limit as an
         // implementation detail.
@@ skipping 35 matching lines @@
         // receiving fewer than requsted records does not necessarily mean that more
         // records are not available.
         //
         // Returns nil if retrieval executed successfully, ErrDoesNotExist if
         // the requested stream does not exist, and an error if an error occurred
         // during retrieval.
         Get(GetRequest, GetCallback) error
 
         // Tail retrieves the latest log in the stream. If the stream has no logs, it
         // will return ErrDoesNotExist.
-        Tail(types.StreamPath) ([]byte, types.MessageIndex, error)
+        Tail(config.ProjectName, types.StreamPath) ([]byte, types.MessageIndex, error)
 
         // Config installs the supplied configuration parameters into the storage
         // instance.
         Config(Config) error
 }