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

Unified Diff: logdog/appengine/coordinator/coordinatorTest/context.go

Issue 2435113002: LogDog: Add Storage-layer data caching. (Closed)
Patch Set: Fix byteLimit bug. Created 4 years, 2 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 | « no previous file | logdog/appengine/coordinator/coordinatorTest/service.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: logdog/appengine/coordinator/coordinatorTest/context.go
diff --git a/logdog/appengine/coordinator/coordinatorTest/context.go b/logdog/appengine/coordinator/coordinatorTest/context.go
index 0ec063574f23d95e62095376d445dcf5d56ab5b9..a4848cbd7ddcfff39e02fc994470055023124012 100644
--- a/logdog/appengine/coordinator/coordinatorTest/context.go
+++ b/logdog/appengine/coordinator/coordinatorTest/context.go
@@ -9,8 +9,6 @@ import (
"strings"
"time"
- ds "github.com/luci/gae/service/datastore"
- "github.com/luci/gae/service/info"
"github.com/luci/luci-go/common/clock"
"github.com/luci/luci-go/common/clock/testclock"
luciConfig "github.com/luci/luci-go/common/config"
@@ -23,14 +21,16 @@ import (
"github.com/luci/luci-go/logdog/api/config/svcconfig"
"github.com/luci/luci-go/logdog/appengine/coordinator"
"github.com/luci/luci-go/logdog/appengine/coordinator/config"
- "github.com/luci/luci-go/logdog/common/storage"
- memoryStorage "github.com/luci/luci-go/logdog/common/storage/memory"
+ "github.com/luci/luci-go/logdog/common/storage/caching"
"github.com/luci/luci-go/server/auth"
"github.com/luci/luci-go/server/auth/authtest"
"github.com/luci/luci-go/server/auth/identity"
"github.com/luci/luci-go/server/settings"
"github.com/luci/luci-go/tumble"
+ ds "github.com/luci/gae/service/datastore"
+ "github.com/luci/gae/service/info"
+
"github.com/golang/protobuf/proto"
"golang.org/x/net/context"
)
@@ -56,15 +56,15 @@ type Environment struct {
// Services is the set of installed Coordinator services.
Services Services
- // IntermediateStorage is the memory Intermediate Storage instance
- // installed (by default) into Services.
- IntermediateStorage memoryStorage.Storage
// GSClient is the test GSClient instance installed (by default) into
// Services.
GSClient GSClient
// ArchivalPublisher is the test ArchivalPublisher instance installed (by
// default) into Services.
ArchivalPublisher ArchivalPublisher
+
+ // StorageCache is the default storage cache instance.
+ StorageCache StorageCache
}
// LogIn installs an testing identity into the testing auth state.
@@ -164,7 +164,11 @@ func (e *Environment) addConfigEntry(configSet, path, content string) {
// it, returning the Environment to which they're bound.
func Install() (context.Context, *Environment) {
e := Environment{
- Config: make(map[string]memory.ConfigSet),
+ Config: make(map[string]memory.ConfigSet),
+ GSClient: GSClient{},
+ StorageCache: StorageCache{
+ Base: &coordinator.StorageCache{},
+ },
}
// Get our starting context. This installs, among other things, in-memory
@@ -279,15 +283,15 @@ func Install() (context.Context, *Environment) {
// Setup our default Coordinator services.
e.Services = Services{
- IS: func() (storage.Storage, error) {
- return &e.IntermediateStorage, nil
- },
GS: func() (gs.Client, error) {
return &e.GSClient, nil
},
AP: func() (coordinator.ArchivalPublisher, error) {
return &e.ArchivalPublisher, nil
},
+ SC: func() caching.Cache {
+ return &e.StorageCache
+ },
}
c = coordinator.WithServices(c, &e.Services)
« no previous file with comments | « no previous file | logdog/appengine/coordinator/coordinatorTest/service.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698