libtokyocabinet Queue Storage Functions

Data Structures
struct	gearman_queue_libtokyocabinet_st
Functions
static gearman_return_t	_libtokyocabinet_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	_libtokyocabinet_flush (gearman_server_st *server, void *context)
static gearman_return_t	_libtokyocabinet_done (gearman_server_st *server, void *context, const void *unique, size_t unique_size, const void *function_name, size_t function_name_size)
static gearman_return_t	_libtokyocabinet_replay (gearman_server_st *server, void *context, gearman_queue_add_fn *add_fn, void *add_context)
static const char *	_libtokyocabinet_tcaerrmsg (TCADB *db)
gearman_return_t	gearman_server_queue_libtokyocabinet_conf (gearman_conf_st *conf)
gearman_return_t	gearman_queue_libtokyocabinet_init (gearman_server_st *server, gearman_conf_st *conf)
gearman_return_t	gearman_queue_libtokyocabinet_deinit (gearman_server_st *server)
gearman_return_t	gearmand_queue_libtokyocabinet_init (gearmand_st *gearmand, gearman_conf_st *conf)
gearman_return_t	gearmand_queue_libtokyocabinet_deinit (gearmand_st *gearmand)
static gearman_return_t	_libtokyocabinet_flush (gearman_server_st *server, void *context __attribute__((unused)))
static gearman_return_t	_callback_for_record (gearman_server_st *server, TCXSTR *key, TCXSTR *data, gearman_queue_add_fn *add_fn, void *add_context)

---

Function Documentation

static gearman_return_t _libtokyocabinet_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 207 of file queue_libtokyocabinet.c.

static gearman_return_t _libtokyocabinet_flush	(	gearman_server_st *	server,
		void *	context
	)			[static]

static gearman_return_t _libtokyocabinet_done	(	gearman_server_st *	server,
		void *	context,
		const void *	unique,
		size_t	unique_size,
		const void *	function_name,
		size_t	function_name_size
	)			[static]

Definition at line 281 of file queue_libtokyocabinet.c.

static gearman_return_t _libtokyocabinet_replay	(	gearman_server_st *	server,
		void *	context,
		gearman_queue_add_fn *	add_fn,
		void *	add_context
	)			[static]

Definition at line 378 of file queue_libtokyocabinet.c.

static const char* _libtokyocabinet_tcaerrmsg

(

TCADB *

db

)

[static]

Missing function from tcadb.c ??

Definition at line 51 of file queue_libtokyocabinet.c.

gearman_return_t gearman_server_queue_libtokyocabinet_conf

(

gearman_conf_st *

conf

)

Get module configuration options.

gearman_return_t gearman_queue_libtokyocabinet_init	(	gearman_server_st *	server,
		gearman_conf_st *	conf
	)

Initialize the queue.

gearman_return_t gearman_queue_libtokyocabinet_deinit

(

gearman_server_st *

server

)

De-initialize the queue.

gearman_return_t gearmand_queue_libtokyocabinet_init	(	gearmand_st *	gearmand,
		gearman_conf_st *	conf
	)

Initialize the queue for a gearmand object.

gearman_return_t gearmand_queue_libtokyocabinet_deinit

(

gearmand_st *

server

)

De-initialize the queue for a gearmand object.

static gearman_return_t _libtokyocabinet_flush	(	gearman_server_st *	server,
		void *context	__attribute__(unused)
	)			[static]

Definition at line 268 of file queue_libtokyocabinet.c.

static gearman_return_t _callback_for_record	(	gearman_server_st *	server,
		TCXSTR *	key,
		TCXSTR *	data,
		gearman_queue_add_fn *	add_fn,
		void *	add_context
	)			[static]

Definition at line 312 of file queue_libtokyocabinet.c.