X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fdma%2Fvendor%2Fgithub.com%2Fgo-redis%2Fredis%2Fpipeline.go;h=b3a8844af036471b36bab19d97bc52d546b7c6ba;hb=4d11ca17d0f73f5bd783f45900118295fdfed46b;hp=ba852283ed8f10d1463b3d7e3e2fcbf8f8843008;hpb=b52c942a4fbfc5023780d23954de953b817c6dc0;p=barometer.git

diff --git a/src/dma/vendor/github.com/go-redis/redis/pipeline.go b/src/dma/vendor/github.com/go-redis/redis/pipeline.go
index ba852283..b3a8844a 100644
--- a/src/dma/vendor/github.com/go-redis/redis/pipeline.go
+++ b/src/dma/vendor/github.com/go-redis/redis/pipeline.go
@@ -10,6 +10,7 @@ type pipelineExecer func([]Cmder) error
 
 type Pipeliner interface {
 	StatefulCmdable
+	Do(args ...interface{}) *Cmd
 	Process(cmd Cmder) error
 	Close() error
 	Discard() error
@@ -31,6 +32,12 @@ type Pipeline struct {
 	closed bool
 }
 
+func (c *Pipeline) Do(args ...interface{}) *Cmd {
+	cmd := NewCmd(args...)
+	_ = c.Process(cmd)
+	return cmd
+}
+
 // Process queues the cmd for later execution.
 func (c *Pipeline) Process(cmd Cmder) error {
 	c.mu.Lock()