persistence.h

Go to the documentation of this file.

/*
 *    Transformer Persistence
 *
 *    Copyright CAPLIN Systems Ltd 2000-2014
 *
 *
 *    $Author: christophs $
 *    $DateTime: 2014/01/21 15:46:13 $
 *    $Change: 282187 $
 *    $Id: //CDev/main/rtas/modules/cluster/cluster.h#5 $
 *
 *
 */

#ifndef PERSIST_H
#define PERSIST_H

#include "transformer.h"


#define PERSISTENCE_SEND_CLUSTER   1
#define PERSISTENCE_SEND_LISTENERS 2


typedef void (*persistence_rebalance_cb)(void *context, const char *key, const char *value);


typedef void (*persistence_query_cb)(void *context, const char *key, const char *value);


typedef struct {
    void      (*key_updated)(void *ctx, const char *key, const char *value); 
    void      (*key_deleted)(void *ctx, const char *key); 
} persistence_listener_t;


typedef struct {
    int          version;        
    int          patch;          
    int        (*replicate_should_enable)(const char *key); /*< Load balance helper */
    void       (*replicate_send_update)(ds_data_t *dsdata); /*< send update to cluster nodes */
    void       (*replicate_add_rebalance_listener)(const char *query_prefix, persistence_rebalance_cb cb, void *context);
    int        (*persist_add_key)(const char *key, const char *value,  int flags); 
    int        (*persist_delete_key)(const char *key, int flags); 
    char      *(*persist_get)(const char *identifier); 
    void       (*persist_query)( const char *query, persistence_query_cb callback, void *context); 
    void       (*replicate_add_change_listener)(const char *prefix, persistence_listener_t *listener, void *ctx); 
} persistence_interface_t;


#endif  /* PERSIST_H */