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

Unified Diff: appengine/gaeconfig/cache_test.go

Issue 2575383002: Add server/cache support to gaeconfig. (Closed)
Patch Set: Un-collapse. Created 3 years, 11 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 | « appengine/gaeconfig/cache.go ('k') | appengine/gaeconfig/default.go » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: appengine/gaeconfig/cache_test.go
diff --git a/appengine/gaeconfig/cache_test.go b/appengine/gaeconfig/cache_test.go
deleted file mode 100644
index 984cfba8b7f7d3445c1ba720d2a7c202855ef23e..0000000000000000000000000000000000000000
--- a/appengine/gaeconfig/cache_test.go
+++ /dev/null
@@ -1,99 +0,0 @@
-// Copyright 2016 The LUCI Authors. All rights reserved.
-// Use of this source code is governed under the Apache License, Version 2.0
-// that can be found in the LICENSE file.
-
-package gaeconfig
-
-import (
- "testing"
- "time"
-
- "golang.org/x/net/context"
-
- "github.com/luci/gae/filter/featureBreaker"
- "github.com/luci/gae/impl/memory"
- mc "github.com/luci/gae/service/memcache"
- "github.com/luci/luci-go/common/clock/testclock"
- "github.com/luci/luci-go/common/data/caching/proccache"
-
- . "github.com/luci/luci-go/common/testing/assertions"
- . "github.com/smartystreets/goconvey/convey"
-)
-
-func TestCache(t *testing.T) {
- t.Parallel()
-
- Convey("Test cache", t, func() {
- c := context.Background()
- c = memory.Use(c)
-
- pc := &proccache.Cache{}
- c = proccache.Use(c, pc)
- c, clk := testclock.UseTime(c, testclock.TestTimeUTC)
- _ = clk
-
- c, mcFB := featureBreaker.FilterMC(c, nil)
-
- cache := &cache{}
-
- Convey("Should be able to store stuff", func() {
- Convey("memcache+proccache", func() {
- cache.Store(c, "item", time.Second, []byte("foobar"))
- itm, err := mc.GetKey(c, string(cacheKey("item")))
- So(err, ShouldBeNil)
- So(itm.Value(), ShouldResemble, []byte("\xff\xf4\xea\x9c\xf7\xd8\xde\xdc\x01foobar"))
- val, ok := proccache.Get(c, cacheKey("item"))
- So(ok, ShouldBeTrue)
- So(val, ShouldResemble, []byte("foobar"))
-
- Convey("and get it back", func() {
- So(cache.Retrieve(c, "item"), ShouldResemble, []byte("foobar"))
-
- Convey("unless it's expired", func() {
- clk.Add(time.Second * 2)
- So(cache.Retrieve(c, "item"), ShouldBeNil)
- })
-
- Convey("when missing from proccache", func() {
- proccache.GetCache(c).Mutate(cacheKey("item"), func(*proccache.Entry) *proccache.Entry {
- return nil
- })
- So(cache.Retrieve(c, "item"), ShouldResemble, []byte("foobar"))
- })
-
- Convey("unless memcache is corrupt", func() {
- proccache.GetCache(c).Mutate(cacheKey("item"), func(*proccache.Entry) *proccache.Entry {
- return nil
- })
- err := mc.Set(c, mc.NewItem(c, string(cacheKey("item"))).SetValue([]byte("\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff")))
- So(err, ShouldBeNil)
-
- So(cache.Retrieve(c, "item"), ShouldBeNil)
- })
-
- })
- })
-
- Convey("if memcache is down", func() {
- mcFB.BreakFeatures(nil, "SetMulti")
-
- cache.Store(c, "item", time.Second, []byte("foobar"))
- _, err := mc.GetKey(c, string(cacheKey("item")))
- So(err, ShouldErrLike, mc.ErrCacheMiss)
-
- val, ok := proccache.Get(c, cacheKey("item"))
- So(ok, ShouldBeTrue)
- So(val, ShouldResemble, []byte("foobar"))
-
- Convey("and still get it back", func() {
- So(cache.Retrieve(c, "item"), ShouldResemble, []byte("foobar"))
-
- Convey("unless it's expired", func() {
- clk.Add(time.Second * 2)
- So(cache.Retrieve(c, "item"), ShouldBeNil)
- })
- })
- })
- })
- })
-}
« no previous file with comments | « appengine/gaeconfig/cache.go ('k') | appengine/gaeconfig/default.go » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698