summaryrefslogtreecommitdiffstats
path: root/vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go
diff options
context:
space:
mode:
authorChristopher Speller <crspeller@gmail.com>2017-11-13 09:09:58 -0800
committerGitHub <noreply@github.com>2017-11-13 09:09:58 -0800
commit1329aa51b605cb54ba9aae3a82a0a87b881fb7b3 (patch)
tree93cbf354ab894a560fc2cef8ef685d681b4ff889 /vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go
parent7304a61ef597970be3031b14e652fb3a4df44304 (diff)
downloadchat-1329aa51b605cb54ba9aae3a82a0a87b881fb7b3.tar.gz
chat-1329aa51b605cb54ba9aae3a82a0a87b881fb7b3.tar.bz2
chat-1329aa51b605cb54ba9aae3a82a0a87b881fb7b3.zip
Updating server dependancies. (#7816)
Diffstat (limited to 'vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go')
-rw-r--r--vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go85
1 files changed, 0 insertions, 85 deletions
diff --git a/vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go b/vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go
deleted file mode 100644
index d47b635d2..000000000
--- a/vendor/gopkg.in/throttled/throttled.v2/store/redigostore/redisstore_test.go
+++ /dev/null
@@ -1,85 +0,0 @@
-package redigostore_test
-
-import (
- "testing"
- "time"
-
- "github.com/garyburd/redigo/redis"
-
- "gopkg.in/throttled/throttled.v2/store/redigostore"
- "gopkg.in/throttled/throttled.v2/store/storetest"
-)
-
-const (
- redisTestDB = 1
- redisTestPrefix = "throttled:"
-)
-
-func getPool() *redis.Pool {
- pool := &redis.Pool{
- MaxIdle: 3,
- IdleTimeout: 30 * time.Second,
- Dial: func() (redis.Conn, error) {
- return redis.Dial("tcp", ":6379")
- },
- TestOnBorrow: func(c redis.Conn, t time.Time) error {
- _, err := c.Do("PING")
- return err
- },
- }
- return pool
-}
-
-func TestRedisStore(t *testing.T) {
- c, st := setupRedis(t, 0)
- defer c.Close()
- defer clearRedis(c)
-
- clearRedis(c)
- storetest.TestGCRAStore(t, st)
- storetest.TestGCRAStoreTTL(t, st)
-}
-
-func BenchmarkRedisStore(b *testing.B) {
- c, st := setupRedis(b, 0)
- defer c.Close()
- defer clearRedis(c)
-
- storetest.BenchmarkGCRAStore(b, st)
-}
-
-func clearRedis(c redis.Conn) error {
- keys, err := redis.Values(c.Do("KEYS", redisTestPrefix+"*"))
- if err != nil {
- return err
- }
-
- if _, err := redis.Int(c.Do("DEL", keys...)); err != nil {
- return err
- }
-
- return nil
-}
-
-func setupRedis(tb testing.TB, ttl time.Duration) (redis.Conn, *redigostore.RedigoStore) {
- pool := getPool()
- c := pool.Get()
-
- if _, err := redis.String(c.Do("PING")); err != nil {
- c.Close()
- tb.Skip("redis server not available on localhost port 6379")
- }
-
- if _, err := redis.String(c.Do("SELECT", redisTestDB)); err != nil {
- c.Close()
- tb.Fatal(err)
- }
-
- st, err := redigostore.New(pool, redisTestPrefix, redisTestDB)
- if err != nil {
- c.Close()
- tb.Fatal(err)
- }
-
- return c, st
-}