forked from mirror/redis
Fix typo in ClusterClient.TxPipelined()
It should be using ClusterClient.TxPipeline() and not ClusterClient.Pipeline().
This commit is contained in:
parent
15786cf821
commit
8c21ec0006
|
@ -807,7 +807,7 @@ func (c *ClusterClient) TxPipeline() *Pipeline {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *ClusterClient) TxPipelined(fn func(*Pipeline) error) ([]Cmder, error) {
|
func (c *ClusterClient) TxPipelined(fn func(*Pipeline) error) ([]Cmder, error) {
|
||||||
return c.Pipeline().pipelined(fn)
|
return c.TxPipeline().pipelined(fn)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *ClusterClient) txPipelineExec(cmds []Cmder) error {
|
func (c *ClusterClient) txPipelineExec(cmds []Cmder) error {
|
||||||
|
|
Loading…
Reference in New Issue