redis_test.go

package cachita

import (
    "os"
    "testing"
    "time"

    "github.com/stretchr/testify/assert"
)

func TestNewRedisCache(t *testing.T) {
    t.Parallel()
    newCache(rc(t), t)
}

func TestRedisCacheExpires(t *testing.T) {
    t.Parallel()
    cacheExpires(rc(t), t, time.Second, 1200*time.Millisecond)
}

func TestRedisCacheWithInt(t *testing.T) {
    t.Parallel()
    cacheWithInt(rc(t), t)
}
func BenchmarkRedisCacheWithInt(b *testing.B) {
    benchmarkCacheWithInt(rc(b), b)
}

func TestRedisCacheWithString(t *testing.T) {
    t.Parallel()
    cacheWithString(rc(t), t)
}

func BenchmarkRedisCacheWithString(b *testing.B) {
    benchmarkCacheWithString(rc(b), b)
}

func TestRedisCacheWithMapInterface(t *testing.T) {
    t.Parallel()
    cacheWithMapInterface(rc(t), t)
}

func BenchmarkRedisCacheWithMapInterface(b *testing.B) {
    benchmarkCacheWithMapInterface(rc(b), b)
}

func TestRedisCacheWithStruct(t *testing.T) {
    t.Parallel()
    cacheWithStruct(rc(t), t)
}

func BenchmarkRedisCacheWithStruct(b *testing.B) {
    benchmarkCacheWithStruct(rc(b), b)
}

func TestRedis_Incr(t *testing.T) {
    t.Parallel()
    cacheIncr(rc(t), t)
}

func BenchmarkRedis_Incr(b *testing.B) {
    benchmarkCacheIncr(rc(b), b)
}

func rc(t assert.TestingT) (c Cache) {
    h := "127.0.0.1"
    if os.Getenv("REDIS_HOST") != "" {
        h = os.Getenv("REDIS_HOST")
    }
    p := "6379"
    if os.Getenv("REDIS_PORT") != "" {
        h = os.Getenv("REDIS_PORT")
    }
    c, err := Redis(h + ":" + p)
    isError(err, t)
    return
}

func TestRedis_Tag(t *testing.T) {
    t.Parallel()
    cacheTag(rc(t), t)
}

func BenchmarkRedis_Tag(b *testing.B) {
    benchmarkCacheTag(rc(b), b)
}