add redis_client_pipeline in all redis commands

lib_acl_cpp/include/acl_cpp/redis/redis.hpp

@@ -61,6 +61,14 @@ public:
 	 */
 	redis(redis_client_cluster* cluster);
 
+	/**
+	 * pipeline 方式的构造函数
+	 * the constructor in redis pipeline mode
+	 * @param pipeline {redis_client_pipeline*} pipeline 对象
+	 *  the redis pipeline object
+	 */
+	redis(redis_client_pipeline* pipeline);
+
 	ACL_CPP_DEPRECATED
 	redis(redis_client_cluster* cluster, size_t max_conns);
 

lib_acl_cpp/include/acl_cpp/redis/redis_cluster.hpp

@@ -36,6 +36,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_cluster(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_cluster(redis_client_pipeline* pipeline);
+
 	virtual ~redis_cluster(void);
 
 	/**

lib_acl_cpp/include/acl_cpp/redis/redis_connection.hpp

@@ -36,6 +36,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_connection(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_connection(redis_client_pipeline* pipeline);
+
 	virtual ~redis_connection(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_geo.hpp

@@ -92,8 +92,6 @@ private:
 	double latitude_;
 };
 
-class redis_client;
-
 class ACL_CPP_API redis_geo : virtual public redis_command
 {
 public:
@@ -114,6 +112,9 @@ public:
 
 	ACL_CPP_DEPRECATED
 	redis_geo(redis_client_cluster* cluster, size_t max_conns);
+
+	redis_geo(redis_client_pipeline* pipeline);
+
 	virtual ~redis_geo();
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_hash.hpp

@@ -10,8 +10,6 @@
 namespace acl
 {
 
-class redis_client;
-
 /**
  * redis Hash(哈希表) 类，本类的实现的主要命令：
  * redis Hash class, include commands as below:
@@ -39,6 +37,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_hash(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_hash(redis_client_pipeline* pipeline);
+
 	virtual ~redis_hash(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_hyperloglog.hpp

@@ -9,9 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_client_cluster;
-
 class ACL_CPP_API redis_hyperloglog : virtual public redis_command
 {
 public:
@@ -33,6 +30,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_hyperloglog(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_hyperloglog(redis_client_pipeline* pipeline);
+
 	virtual ~redis_hyperloglog(void);
 
 	/**

lib_acl_cpp/include/acl_cpp/redis/redis_key.hpp

@@ -8,9 +8,6 @@
 
 namespace acl {
 
-class redis_client;
-class redis_client_cluster;
-
 // redis 服务支持的数据类型分类
 // the data type supported by redis
 typedef enum
@@ -44,6 +41,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_key(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_key(redis_client_pipeline* pipeline);
+
 	virtual ~redis_key(void);
 
 	/**

lib_acl_cpp/include/acl_cpp/redis/redis_list.hpp

@@ -7,8 +7,6 @@
 namespace acl
 {
 
-class redis_client;
-
 class ACL_CPP_API redis_list : virtual public redis_command
 {
 public:
@@ -30,6 +28,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_list(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_list(redis_client_pipeline* pipeline);
+
 	virtual ~redis_list(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_pubsub.hpp

@@ -9,10 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_result;
-class string;
-
 class ACL_CPP_API redis_pubsub : virtual public redis_command
 {
 public:
@@ -34,6 +30,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_pubsub(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_pubsub(redis_client_pipeline* pipeline);
+
 	virtual ~redis_pubsub(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_script.hpp

@@ -9,9 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_result;
-
 class ACL_CPP_API redis_script : virtual public redis_command
 {
 public:
@@ -33,6 +30,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_script(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_script(redis_client_pipeline* pipeline);
+
 	virtual ~redis_script(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_server.hpp

@@ -9,9 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_result;
-
 class ACL_CPP_API redis_server : virtual public redis_command
 {
 public:
@@ -33,6 +30,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_server(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_server(redis_client_pipeline* pipeline);
+
 	virtual ~redis_server(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_set.hpp

@@ -9,8 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-
 class ACL_CPP_API redis_set : virtual public redis_command
 {
 public:
@@ -32,6 +30,8 @@ public:
 	ACL_CPP_DEPRECATED
 	redis_set(redis_client_cluster* cluster, size_t max_conns);
 
+	redis_set(redis_client_pipeline* pipeline);
+
 	virtual ~redis_set(void);
 
 	/////////////////////////////////////////////////////////////////////

lib_acl_cpp/include/acl_cpp/redis/redis_stream.hpp

@@ -8,9 +8,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_client_cluster;
-
 struct redis_stream_field
 {
 	string name;
@@ -148,6 +145,7 @@ public:
 	redis_stream(void);
 	redis_stream(redis_client* conn);
 	redis_stream(redis_client_cluster* cluster);
+	redis_stream(redis_client_pipeline* pipeline);
 
 	ACL_CPP_DEPRECATED
 	redis_stream(redis_client_cluster* cluster, size_t max_conns);

lib_acl_cpp/include/acl_cpp/redis/redis_string.hpp

@@ -9,10 +9,6 @@
 namespace acl
 {
 
-class string;
-class redis_client;
-class redis_result;
-
 /**
  * 所有的字符串对象的命令都已实现
  * all the commands in redis Strings are be implemented.
@@ -35,6 +31,8 @@ public:
 	 */
 	redis_string(redis_client_cluster* cluster);
 
+	redis_string(redis_client_pipeline* pipeline);
+
 	ACL_CPP_DEPRECATED
 	redis_string(redis_client_cluster* cluster, size_t max_conns);
 

lib_acl_cpp/include/acl_cpp/redis/redis_transaction.hpp

@@ -9,9 +9,6 @@
 namespace acl
 {
 
-class redis_client;
-class redis_result;
-
 class ACL_CPP_API redis_transaction : virtual public redis_command
 {
 public:
@@ -30,6 +27,8 @@ public:
 	 */
 	redis_transaction(redis_client_cluster* cluster);
 
+	redis_transaction(redis_client_pipeline* pipeline);
+
 	ACL_CPP_DEPRECATED
 	redis_transaction(redis_client_cluster* cluster, size_t max_conns);
 

lib_acl_cpp/include/acl_cpp/redis/redis_zset.hpp

@@ -10,8 +10,6 @@
 namespace acl
 {
 
-class redis_client;
-
 class ACL_CPP_API redis_zset : virtual public redis_command
 {
 public:
@@ -30,6 +28,8 @@ public:
 	 */
 	redis_zset(redis_client_cluster* cluster);
 
+	redis_zset(redis_client_pipeline* pipeline);
+
 	ACL_CPP_DEPRECATED
 	redis_zset(redis_client_cluster* cluster, size_t max_conns);
 

lib_acl_cpp/src/redis/redis.cpp

@@ -44,6 +44,25 @@ redis::redis(redis_client_cluster* cluster)
 {
 }
 
+redis::redis(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+, redis_connection(pipeline)
+, redis_hash(pipeline)
+, redis_hyperloglog(pipeline)
+, redis_key(pipeline)
+, redis_list(pipeline)
+, redis_pubsub(pipeline)
+, redis_script(pipeline)
+, redis_server(pipeline)
+, redis_set(pipeline)
+, redis_string(pipeline)
+, redis_transaction(pipeline)
+, redis_zset(pipeline)
+, redis_cluster(pipeline)
+{
+}
+
+
 redis::redis(redis_client_cluster* cluster, size_t)
 : redis_command(cluster)
 , redis_connection(cluster)

lib_acl_cpp/src/redis/redis_cluster.cpp

@@ -29,6 +29,11 @@ redis_cluster::redis_cluster(redis_client_cluster* cluster)
 {
 }
 
+redis_cluster::redis_cluster(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_cluster::redis_cluster(redis_client_cluster* cluster, size_t)
 : redis_command(cluster)
 {

lib_acl_cpp/src/redis/redis_connection.cpp

@@ -30,6 +30,11 @@ redis_connection::redis_connection(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_connection::redis_connection(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_connection::~redis_connection()
 {
 }

lib_acl_cpp/src/redis/redis_geo.cpp

@@ -80,6 +80,11 @@ redis_geo::redis_geo(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_geo::redis_geo(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_geo::~redis_geo()
 {
 }

lib_acl_cpp/src/redis/redis_hash.cpp

@@ -33,6 +33,11 @@ redis_hash::redis_hash(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_hash::redis_hash(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_hash::~redis_hash(void)
 {
 }

lib_acl_cpp/src/redis/redis_hyperloglog.cpp

@@ -28,6 +28,11 @@ redis_hyperloglog::redis_hyperloglog(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_hyperloglog::redis_hyperloglog(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_hyperloglog::~redis_hyperloglog()
 {
 }

lib_acl_cpp/src/redis/redis_key.cpp

@@ -34,6 +34,11 @@ redis_key::redis_key(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_key::redis_key(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_key::~redis_key()
 {
 }

lib_acl_cpp/src/redis/redis_list.cpp

@@ -35,6 +35,11 @@ redis_list::redis_list(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_list::redis_list(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_list::~redis_list()
 {
 }

lib_acl_cpp/src/redis/redis_pubsub.cpp

@@ -31,6 +31,11 @@ redis_pubsub::redis_pubsub(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_pubsub::redis_pubsub(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_pubsub::~redis_pubsub(void)
 {
 }

lib_acl_cpp/src/redis/redis_script.cpp

@@ -33,6 +33,11 @@ redis_script::redis_script(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_script::redis_script(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_script::~redis_script()
 {
 }

lib_acl_cpp/src/redis/redis_server.cpp

@@ -32,6 +32,11 @@ redis_server::redis_server(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_server::redis_server(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_server::~redis_server()
 {
 }

lib_acl_cpp/src/redis/redis_set.cpp

@@ -33,6 +33,11 @@ redis_set::redis_set(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_set::redis_set(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_set::~redis_set()
 {
 }

lib_acl_cpp/src/redis/redis_stream.cpp

@@ -33,6 +33,11 @@ redis_stream::redis_stream(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_stream::redis_stream(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_stream::~redis_stream(void)
 {
 }

lib_acl_cpp/src/redis/redis_string.cpp

@@ -36,6 +36,11 @@ redis_string::redis_string(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_string::redis_string(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_string::~redis_string()
 {
 }

lib_acl_cpp/src/redis/redis_transaction.cpp

@@ -30,6 +30,11 @@ redis_transaction::redis_transaction(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_transaction::redis_transaction(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_transaction::~redis_transaction()
 {
 }

lib_acl_cpp/src/redis/redis_zset.cpp

@@ -34,6 +34,11 @@ redis_zset::redis_zset(redis_client_cluster* cluster, size_t)
 {
 }
 
+redis_zset::redis_zset(redis_client_pipeline* pipeline)
+: redis_command(pipeline)
+{
+}
+
 redis_zset::~redis_zset()
 {
 }