#include <redis_client_pipeline.hpp>

类 acl::redis_client_pipeline 继承关系图:

acl::redis_client_pipeline 的协作图:

Public 成员函数
	redis_client_pipeline (const char *addr)

	~redis_client_pipeline (void)

void	start_thread (void)

void	stop_thread (void)

const redis_result *	run (redis_pipeline_message &msg)

void	push (redis_pipeline_message *msg)

redis_client_pipeline &	set_password (const char *passwd)

redis_client_pipeline &	set_timeout (int conn_timeout, int rw_timeout)

redis_client_pipeline &	set_retry (bool on)

redis_client_pipeline &	set_max_slot (int max_slot)

redis_client_pipeline &	set_preconnect (bool yes)

int	get_max_slot (void) const

Public 成员函数继承自 acl::acl::thread
	thread (void)

virtual	~thread (void)

bool	start (bool sync=false)

bool	wait (void **out=NULL)

thread &	set_detachable (bool yes)

thread &	set_stacksize (size_t size)

unsigned long	thread_id (void) const

Public 成员函数继承自 acl::acl::thread_job
	thread_job (void)

virtual	~thread_job (void)

virtual void	init (void)

Protected 成员函数
void *	run (void)

Protected 成员函数继承自 acl::acl::noncopyable
	noncopyable ()

	~noncopyable ()

额外继承的成员函数
静态 Public 成员函数继承自 acl::acl::thread
static unsigned long	thread_self (void)

static unsigned long	self (void)

详细描述

redis pipline communication, be set and used in redis_command to improve the performance of redis commands, but not all redis commands in acl can be used in pipeline mode, such as below:

multiple keys operation
blocked operation such as SUBSCRIBE in pubsub, BLPOP in list

在文件 redis_client_pipeline.hpp 第 196 行定义.

构造及析构函数说明

◆ redis_client_pipeline()

acl::redis_client_pipeline::redis_client_pipeline ( const char * addr )

◆ ~redis_client_pipeline()

acl::redis_client_pipeline::~redis_client_pipeline ( void )

成员函数说明

◆ get_max_slot()

int acl::redis_client_pipeline::get_max_slot ( void ) const

inline

在文件 redis_client_pipeline.hpp 第 231 行定义.

                                      {
                 return max_slot_;
         }

◆ push()

void acl::redis_client_pipeline::push ( redis_pipeline_message * msg )

◆ run() [1/2]

const redis_result* acl::redis_client_pipeline::run ( redis_pipeline_message & msg )

◆ run() [2/2]

void* acl::redis_client_pipeline::run ( void )

protectedvirtual

实现了 acl::acl::thread_job.

◆ set_max_slot()

redis_client_pipeline& acl::redis_client_pipeline::set_max_slot ( int max_slot )

◆ set_password()

redis_client_pipeline& acl::redis_client_pipeline::set_password ( const char * passwd )

◆ set_preconnect()

redis_client_pipeline& acl::redis_client_pipeline::set_preconnect ( bool yes )

◆ set_retry()

redis_client_pipeline& acl::redis_client_pipeline::set_retry ( bool on )

◆ set_timeout()

redis_client_pipeline& acl::redis_client_pipeline::set_timeout	(	int	conn_timeout,
		int	rw_timeout
	)

◆ start_thread()

void acl::redis_client_pipeline::start_thread ( void )

◆ stop_thread()

void acl::redis_client_pipeline::stop_thread ( void )

该类的文档由以下文件生成:

include/acl_cpp/redis/redis_client_pipeline.hpp

Public 成员函数

Protected 成员函数

额外继承的成员函数