Gearman Developer Documentation

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.

Generated on Tue Jun 15 11:40:21 2010 by  doxygen 1.6.3