Index: server/logdog/storage/bigtable/storage_test.go |
diff --git a/server/logdog/storage/bigtable/storage_test.go b/server/logdog/storage/bigtable/storage_test.go |
index 52025707355656f1acee249374d998bf0c265893..b22a24aab47073e3c04b7c12b06d7d82a4f0d54f 100644 |
--- a/server/logdog/storage/bigtable/storage_test.go |
+++ b/server/logdog/storage/bigtable/storage_test.go |
@@ -11,6 +11,7 @@ import ( |
"time" |
"github.com/luci/gkvlite" |
+ "github.com/luci/luci-go/common/config" |
"github.com/luci/luci-go/common/logdog/types" |
"github.com/luci/luci-go/common/recordio" |
"github.com/luci/luci-go/server/logdog/storage" |
@@ -175,11 +176,13 @@ func testStorageImpl(t *testing.T, legacy bool) { |
s.raw = &bt |
defer s.Close() |
+ project := config.ProjectName("test-project") |
get := func(path string, index int, limit int) ([]string, error) { |
req := storage.GetRequest{ |
- Path: types.StreamPath(path), |
- Index: types.MessageIndex(index), |
- Limit: limit, |
+ Project: project, |
+ Path: types.StreamPath(path), |
+ Index: types.MessageIndex(index), |
+ Limit: limit, |
} |
got := []string{} |
err := s.Get(req, func(idx types.MessageIndex, d []byte) bool { |
@@ -196,14 +199,15 @@ func testStorageImpl(t *testing.T, legacy bool) { |
} |
return s.Put(storage.PutRequest{ |
- Path: types.StreamPath(path), |
- Index: types.MessageIndex(index), |
- Values: data, |
+ Project: project, |
+ Path: types.StreamPath(path), |
+ Index: types.MessageIndex(index), |
+ Values: data, |
}) |
} |
- ekey := func(p string, v, c int64) string { |
- return newRowKey(p, v, c).encode() |
+ ekey := func(path string, v, c int64) string { |
+ return newRowKey(string(project), path, v, c).encode() |
} |
records := func(s ...string) []byte { |
buf := bytes.Buffer{} |
@@ -297,7 +301,7 @@ func testStorageImpl(t *testing.T, legacy bool) { |
Convey(`Testing "Tail"...`, func() { |
tail := func(path string) (string, error) { |
- got, _, err := s.Tail(types.StreamPath(path)) |
+ got, _, err := s.Tail(project, types.StreamPath(path)) |
return string(got), err |
} |