libdrizzle Queue Storage Functions

Data Structures
struct	gearman_queue_libdrizzle_st
Defines
#define	GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_DATABASE "test"
#define	GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_TABLE "queue"
#define	GEARMAN_QUEUE_QUERY_BUFFER 256
Functions
static drizzle_return_t	_libdrizzle_query (gearman_server_st server, gearman_queue_libdrizzle_st queue, const char *query, size_t query_size)
static gearman_return_t	_libdrizzle_add (gearman_server_st server, void context, const void unique, size_t unique_size, const void function_name, size_t function_name_size, const void *data, size_t data_size, gearman_job_priority_t priority)
static gearman_return_t	_libdrizzle_flush (gearman_server_st gearman, void context)
static gearman_return_t	_libdrizzle_done (gearman_server_st gearman, void context, const void unique, size_t unique_size, const void function_name, size_t function_name_size)
static gearman_return_t	_libdrizzle_replay (gearman_server_st gearman, void context, gearman_queue_add_fn add_fn, void add_context)
gearman_return_t	gearman_server_queue_libdrizzle_conf (gearman_conf_st *conf)
gearman_return_t	gearman_server_queue_libdrizzle_init (gearman_server_st server, gearman_conf_st conf)
gearman_return_t	gearman_server_queue_libdrizzle_deinit (gearman_server_st *server)
gearman_return_t	gearmand_queue_libdrizzle_init (gearmand_st gearmand, gearman_conf_st conf)
gearman_return_t	gearmand_queue_libdrizzle_deinit (gearmand_st *gearmand)

Define Documentation

#define GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_DATABASE "test"

Default values.

Definition at line 28 of file queue_libdrizzle.c.

#define GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_TABLE "queue"

Definition at line 29 of file queue_libdrizzle.c.

#define GEARMAN_QUEUE_QUERY_BUFFER 256

Definition at line 30 of file queue_libdrizzle.c.

static drizzle_return_t _libdrizzle_query	(	gearman_server_st *	server,
		gearman_queue_libdrizzle_st *	queue,
		const char *	query,
		size_t	query_size
	)			`[static]`

Query error handling function.

Definition at line 295 of file queue_libdrizzle.c.

static gearman_return_t _libdrizzle_add	(	gearman_server_st *	server,
		void *	context,
		const void *	unique,
		size_t	unique_size,
		const void *	function_name,
		size_t	function_name_size,
		const void *	data,
		size_t	data_size,
		gearman_job_priority_t	priority
	)			`[static]`

Definition at line 325 of file queue_libdrizzle.c.

static gearman_return_t _libdrizzle_flush	(	gearman_server_st *	gearman,
		void *	context
	)			`[static]`

static gearman_return_t _libdrizzle_done	(	gearman_server_st *	gearman,
		void *	context,
		const void *	unique,
		size_t	unique_size,
		const void *	function_name,
		size_t	function_name_size
	)			`[static]`

static gearman_return_t _libdrizzle_replay	(	gearman_server_st *	gearman,
		void *	context,
		gearman_queue_add_fn *	add_fn,
		void *	add_context
	)			`[static]`

Definition at line 450 of file queue_libdrizzle.c.

gearman_return_t gearman_server_queue_libdrizzle_conf ( gearman_conf_st * conf )

Get module configuration options.

Definition at line 82 of file queue_libdrizzle.c.

gearman_return_t gearman_server_queue_libdrizzle_init	(	gearman_server_st *	server,
		gearman_conf_st *	conf
	)

Initialize the queue.

Definition at line 105 of file queue_libdrizzle.c.

gearman_return_t gearman_server_queue_libdrizzle_deinit ( gearman_server_st * server )

De-initialize the queue.

Definition at line 263 of file queue_libdrizzle.c.

gearman_return_t gearmand_queue_libdrizzle_init	(	gearmand_st *	gearmand,
		gearman_conf_st *	conf
	)

Initialize the queue for a gearmand object.

Definition at line 280 of file queue_libdrizzle.c.

gearman_return_t gearmand_queue_libdrizzle_deinit ( gearmand_st * gearmand )

De-initialize the queue for a gearmand object.

Definition at line 286 of file queue_libdrizzle.c.