Gearman Developer Documentation

Static libpq Queue Storage Definitions
[libpq Queue Storage Declarations]

Data Structures

struct  gearman_queue_libpq_st

Defines

#define GEARMAN_QUEUE_LIBPQ_DEFAULT_TABLE   "queue"
#define GEARMAN_QUEUE_QUERY_BUFFER   256

Functions

static void _libpq_notice_processor (void *arg, const char *message)
static gearman_return_t _libpq_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 _libpq_flush (gearman_server_st *server, void *context)
static gearman_return_t _libpq_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 _libpq_replay (gearman_server_st *server, void *context, gearman_queue_add_fn *add_fn, void *add_context)

Define Documentation

#define GEARMAN_QUEUE_LIBPQ_DEFAULT_TABLE   "queue"

Default values.

Definition at line 35 of file queue_libpq.c.

#define GEARMAN_QUEUE_QUERY_BUFFER   256

Definition at line 36 of file queue_libpq.c.


Function Documentation

static void _libpq_notice_processor ( void *  arg,
const char *  message 
) [static]

PostgreSQL notification callback.

Definition at line 240 of file queue_libpq.c.

static gearman_return_t _libpq_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 246 of file queue_libpq.c.

static gearman_return_t _libpq_flush ( gearman_server_st server,
void *  context 
) [static]
static gearman_return_t _libpq_done ( gearman_server_st server,
void *  context,
const void *  unique,
size_t  unique_size,
const void *  function_name,
size_t  function_name_size 
) [static]
static gearman_return_t _libpq_replay ( gearman_server_st server,
void *  context,
gearman_queue_add_fn add_fn,
void *  add_context 
) [static]

Definition at line 373 of file queue_libpq.c.

Generated on Mon Jun 14 15:58:45 2010 by  doxygen 1.6.3