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) |
Tokyo Cabinet Queue Storage Definitions.
Definition in file queue_libtokyocabinet.c.