Data Structures | |
struct | gearman_queue_libdrizzle_st |
Defines | |
#define | GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_DATABASE "test" |
#define | GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_TABLE "queue" |
#define | GEARMAN_QUEUE_QUERY_BUFFER 256 |
Functions | |
static drizzle_return_t | _libdrizzle_query (gearman_server_st *server, gearman_queue_libdrizzle_st *queue, const char *query, size_t query_size) |
static gearman_return_t | _libdrizzle_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 | _libdrizzle_flush (gearman_server_st *gearman, void *context) |
static gearman_return_t | _libdrizzle_done (gearman_server_st *gearman, void *context, const void *unique, size_t unique_size, const void *function_name, size_t function_name_size) |
static gearman_return_t | _libdrizzle_replay (gearman_server_st *gearman, void *context, gearman_queue_add_fn *add_fn, void *add_context) |
#define GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_DATABASE "test" |
Default values.
Definition at line 28 of file queue_libdrizzle.c.
#define GEARMAN_QUEUE_LIBDRIZZLE_DEFAULT_TABLE "queue" |
Definition at line 29 of file queue_libdrizzle.c.
#define GEARMAN_QUEUE_QUERY_BUFFER 256 |
Definition at line 30 of file queue_libdrizzle.c.
static drizzle_return_t _libdrizzle_query | ( | gearman_server_st * | server, | |
gearman_queue_libdrizzle_st * | queue, | |||
const char * | query, | |||
size_t | query_size | |||
) | [static] |
Query error handling function.
Definition at line 285 of file queue_libdrizzle.c.
static gearman_return_t _libdrizzle_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 314 of file queue_libdrizzle.c.
static gearman_return_t _libdrizzle_flush | ( | gearman_server_st * | gearman, | |
void * | context | |||
) | [static] |
static gearman_return_t _libdrizzle_done | ( | gearman_server_st * | gearman, | |
void * | context, | |||
const void * | unique, | |||
size_t | unique_size, | |||
const void * | function_name, | |||
size_t | function_name_size | |||
) | [static] |
static gearman_return_t _libdrizzle_replay | ( | gearman_server_st * | gearman, | |
void * | context, | |||
gearman_queue_add_fn * | add_fn, | |||
void * | add_context | |||
) | [static] |
Definition at line 437 of file queue_libdrizzle.c.