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.
Definition at line 68 of file queue_libtokyocabinet.c.
gearman_return_t gearman_queue_libtokyocabinet_init | ( | gearman_server_st * | server, |
gearman_conf_st * | conf | ||
) |
Initialize the queue.
Definition at line 83 of file queue_libtokyocabinet.c.
gearman_return_t gearman_queue_libtokyocabinet_deinit | ( | gearman_server_st * | server | ) |
De-initialize the queue.
Definition at line 177 of file queue_libtokyocabinet.c.
gearman_return_t gearmand_queue_libtokyocabinet_init | ( | gearmand_st * | gearmand, |
gearman_conf_st * | conf | ||
) |
Initialize the queue for a gearmand object.
Definition at line 192 of file queue_libtokyocabinet.c.
gearman_return_t gearmand_queue_libtokyocabinet_deinit | ( | gearmand_st * | server | ) |
De-initialize the queue for a gearmand object.
Definition at line 198 of file queue_libtokyocabinet.c.
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.