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

Unified Diff: server/logdog/storage/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 | « server/logdog/storage/memory/memory_test.go ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: server/logdog/storage/storage.go
diff --git a/server/logdog/storage/storage.go b/server/logdog/storage/storage.go
index 57819b240e8b1a3690aee2ffa88aa950d89e5750..b2e5fd2e1dab7caa278fc8df164db481a5b334b5 100644
--- a/server/logdog/storage/storage.go
+++ b/server/logdog/storage/storage.go
@@ -8,6 +8,7 @@ import (
"errors"
"time"
+ "github.com/luci/luci-go/common/config"
"github.com/luci/luci-go/common/logdog/types"
)
@@ -38,6 +39,8 @@ type Config struct {
// 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.
@@ -50,6 +53,8 @@ type PutRequest struct {
// 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.
@@ -105,7 +110,7 @@ type Storage interface {
// 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.
« no previous file with comments | « server/logdog/storage/memory/memory_test.go ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698