PostgreSQL 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))) |
PostgreSQL Queue Storage Definitions.
Definition in file queue_libpq.c.
#define MCO | ( | __name, | |||
__value, | |||||
__help | ) | gearman_conf_module_add_option(module, __name, 0, __value, __help); |
static gearman_return_t _libpq_flush | ( | gearman_server_st * | server, | |
void *context | __attribute__(unused) | |||
) | [static] |
Definition at line 322 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 330 of file queue_libpq.c.