Gearman Developer Documentation

libgearman-server/queue_libpq.c File Reference

libpq Queue Storage Definitions More...

#include "common.h"
#include <libgearman-server/queue_libpq.h>
#include <postgresql/libpq-fe.h>
#include <postgresql/pg_config_manual.h>

Go to the source code of this file.

Data Structures

struct  gearman_queue_libpq_st

Defines

#define GEARMAN_QUEUE_LIBPQ_DEFAULT_TABLE   "queue"
#define GEARMAN_QUEUE_QUERY_BUFFER   256
#define MCO(__name, __value, __help)   gearman_conf_module_add_option(module, __name, 0, __value, __help);

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)
gearman_return_t gearman_server_queue_libpq_conf (gearman_conf_st *conf)
gearman_return_t gearman_server_queue_libpq_init (gearman_server_st *server, gearman_conf_st *conf)
gearman_return_t gearman_server_queue_libpq_deinit (gearman_server_st *server)
gearman_return_t gearmand_queue_libpq_init (gearmand_st *gearmand, gearman_conf_st *conf)
gearman_return_t gearmand_queue_libpq_deinit (gearmand_st *gearmand)
static gearman_return_t _libpq_flush (gearman_server_st *server, void *context __attribute__((unused)))
static gearman_return_t _libpq_done (gearman_server_st *server, void *context, const void *unique, size_t unique_size, const void *function_name __attribute__((unused)), size_t function_name_size __attribute__((unused)))

Detailed Description

libpq Queue Storage Definitions

Definition in file queue_libpq.c.


Define Documentation

#define MCO ( __name,
__value,
__help   )     gearman_conf_module_add_option(module, __name, 0, __value, __help);

Function Documentation

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

Definition at line 313 of file queue_libpq.c.

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

Definition at line 321 of file queue_libpq.c.

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