| 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{}
|
|
|