persistence.h

Go to the documentation of this file.

/*
 *    Transformer Persistence
 *
 *    Copyright CAPLIN Systems Ltd 2000-2016
 *
 *
 *    $Author$
 *    $DateTime$
 *    $Change$
 *    $Id$
 *
 *
 */

#ifndef PERSIST_H
#define PERSIST_H

#include "transformer.h"


typedef struct {
    char       *field;          
    char       *value;          
} kv_pair;

typedef enum { ASC, DESC } persist_ordering;

typedef struct {
    char                *field;         
    persist_ordering     ord;           
} kv_ord;

typedef struct {
    size_t        selector_count;     
    kv_pair      *selector;           
    size_t        order_count;        
    kv_ord       *ordering;           
    size_t        limit;              
} query_params;

typedef struct {
    size_t    count;      
    kv_pair  *pairs;      
} kv_pair_arr;

typedef void (*persistence_query_cb)(void *context, const kv_pair_arr *row);


typedef struct {
    int          version;        
    int          patch;          
    int        (*persist_upsert)(const char *table, const kv_pair_arr *keys, const kv_pair_arr *data);
    int        (*persist_remove)(const char *table, const kv_pair_arr *selector);
    int        (*persist_query)(const char *table, const char *query, const query_params *params, persistence_query_cb row_cb, void *row_cb_ctx);
    int        (*persist_get)(const char *table, const query_params *params, persistence_query_cb row_cb, void *row_cb_ctx);
    int        (*persist_call)(const char *procedure, const char *const *args, size_t args_count, kv_pair_arr *output_params);
} persistence_interface;

typedef int (*filedb_library_function)(void *ctx, const char *const *args, const size_t args_count, kv_pair_arr *output_params);

typedef void (*register_procedure_cb)(char *function_name, filedb_library_function function);

typedef int (*filedb_init_function)(void *ctx, register_procedure_cb register_procedure_cb);


#endif  /* PERSIST_H */