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

Unified Diff: server/logdog/storage/archive/storage.go

Issue 1909943003: LogDog: Add project support to Storage. (Closed) Base URL: https://github.com/luci/luci-go@logdog-project-coordinator-services
Patch Set: Rebase? 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
« no previous file with comments | « appengine/logdog/coordinator/endpoints/logs/get.go ('k') | server/logdog/storage/bigtable/rowKey.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: server/logdog/storage/archive/storage.go
diff --git a/server/logdog/storage/archive/storage.go b/server/logdog/storage/archive/storage.go
index a6ed17e06b696e1a980c549ae42c45e2dbc49ac9..7e50a20cd96a4d63db4c4b553315addebec26063 100644
--- a/server/logdog/storage/archive/storage.go
+++ b/server/logdog/storage/archive/storage.go
@@ -23,6 +23,7 @@ import (
"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"
@@ -42,8 +43,8 @@ const (
// 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
@@ -204,7 +205,7 @@ func (s *storageImpl) Get(req storage.GetRequest, cb storage.GetCallback) error
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
« no previous file with comments | « appengine/logdog/coordinator/endpoints/logs/get.go ('k') | server/logdog/storage/bigtable/rowKey.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698