summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/go-redis/redis/pipeline_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/go-redis/redis/pipeline_test.go')
-rw-r--r--vendor/github.com/go-redis/redis/pipeline_test.go80
1 files changed, 0 insertions, 80 deletions
diff --git a/vendor/github.com/go-redis/redis/pipeline_test.go b/vendor/github.com/go-redis/redis/pipeline_test.go
deleted file mode 100644
index 11896c6bb..000000000
--- a/vendor/github.com/go-redis/redis/pipeline_test.go
+++ /dev/null
@@ -1,80 +0,0 @@
-package redis_test
-
-import (
- "github.com/go-redis/redis"
-
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
-)
-
-var _ = Describe("pipelining", func() {
- var client *redis.Client
- var pipe *redis.Pipeline
-
- BeforeEach(func() {
- client = redis.NewClient(redisOptions())
- Expect(client.FlushDB().Err()).NotTo(HaveOccurred())
- })
-
- AfterEach(func() {
- Expect(client.Close()).NotTo(HaveOccurred())
- })
-
- It("supports block style", func() {
- var get *redis.StringCmd
- cmds, err := client.Pipelined(func(pipe redis.Pipeliner) error {
- get = pipe.Get("foo")
- return nil
- })
- Expect(err).To(Equal(redis.Nil))
- Expect(cmds).To(HaveLen(1))
- Expect(cmds[0]).To(Equal(get))
- Expect(get.Err()).To(Equal(redis.Nil))
- Expect(get.Val()).To(Equal(""))
- })
-
- assertPipeline := func() {
- It("returns no errors when there are no commands", func() {
- _, err := pipe.Exec()
- Expect(err).NotTo(HaveOccurred())
- })
-
- It("discards queued commands", func() {
- pipe.Get("key")
- pipe.Discard()
- cmds, err := pipe.Exec()
- Expect(err).NotTo(HaveOccurred())
- Expect(cmds).To(BeNil())
- })
-
- It("handles val/err", func() {
- err := client.Set("key", "value", 0).Err()
- Expect(err).NotTo(HaveOccurred())
-
- get := pipe.Get("key")
- cmds, err := pipe.Exec()
- Expect(err).NotTo(HaveOccurred())
- Expect(cmds).To(HaveLen(1))
-
- val, err := get.Result()
- Expect(err).NotTo(HaveOccurred())
- Expect(val).To(Equal("value"))
- })
- }
-
- Describe("Pipeline", func() {
- BeforeEach(func() {
- pipe = client.Pipeline().(*redis.Pipeline)
- })
-
- assertPipeline()
- })
-
- Describe("TxPipeline", func() {
- BeforeEach(func() {
- pipe = client.TxPipeline().(*redis.Pipeline)
- })
-
- assertPipeline()
- })
-})