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

Unified Diff: server/internal/logdog/archivist/storageSource.go

Issue 1909053003: LogDog: Add project namespacing to Archivist. (Closed) Base URL: https://github.com/luci/luci-go@logdog-project-coordinator-logs
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 | « server/internal/logdog/archivist/archivist_test.go ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: server/internal/logdog/archivist/storageSource.go
diff --git a/server/internal/logdog/archivist/storageSource.go b/server/internal/logdog/archivist/storageSource.go
index ae49d172d74c04d1a367b7a6ec51ccd673066e0d..dcf9ee7b41e6b9cddcec139b32f57f5e2af0a429 100644
--- a/server/internal/logdog/archivist/storageSource.go
+++ b/server/internal/logdog/archivist/storageSource.go
@@ -6,6 +6,7 @@ package archivist
import (
"github.com/golang/protobuf/proto"
+ "github.com/luci/luci-go/common/config"
"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"
@@ -20,6 +21,7 @@ type storageSource struct {
context.Context
st storage.Storage // the storage instance to read from
+ project config.ProjectName // the path of the log stream
path types.StreamPath // the path of the log stream
terminalIndex types.MessageIndex // if >= 0, discard logs beyond this
@@ -32,8 +34,9 @@ func (s *storageSource) bufferEntries(start types.MessageIndex) error {
bytes := 0
req := storage.GetRequest{
- Path: s.path,
- Index: start,
+ Project: s.project,
+ Path: s.path,
+ Index: start,
}
return s.st.Get(req, func(idx types.MessageIndex, d []byte) bool {
le := logpb.LogEntry{}
« no previous file with comments | « server/internal/logdog/archivist/archivist_test.go ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698