redisC := service.RedisClusterStart()
defer redisC.Close()
Pipeline := redisC.Pipeline()
Pipeline.Set(context.TODO(), "set", "ffff", time.Second*600)
Pipeline.SAdd(context.TODO(), "sadd", "yuwei", "wuyujia")
exec, err := Pipeline.Exec(context.TODO())
if err != nil {
fmt.Println(err)
return
}
fmt.Println(exec)
github.com/go-redis/redis/v8 包地址