cluster.h

Go to the documentation of this file.

/*
 *    Transformer Clustering
 *
 *    Copyright CAPLIN Systems Ltd 2000-2006
 *
 *
 *    $Author$
 *    $DateTime$
 *    $Change$
 *    $Id$
 *
 *
 */

#ifndef CLUSTER_H
#define CLUSTER_H

#include "transformer.h"
#include "datasrc_extra.h"



#define CLUSTER_ALL_NODES          (-1)


#define CLUSTER_CONNECT_EVENT      "cluster-node-connect"
#define CLUSTER_DISCONNECT_EVENT   "cluster-node-disconnect"

#define CLUSTER_STATE_EVENT        "cluster-state"

#define CLUSTER_PACKET_LOG_VERSION 2 
#define CLUSTER_PACKET_LOG_HEADER  "TCBLog packet v"

typedef struct {
    int          version;        
    int          patch;          
    int         (*cluster_check_primary)();

    void        (*cluster_send_update)(ds_data_t *dsdata);

    void        (*cluster_send_update_to_node)(int node, ds_data_t *dsdata);  

    void        (*cluster_monitor_method)(char *template, char *key, char *property, int argc, char *argv[]);

    void        (*cluster_monitor_method_to_node)(int node, char *template, char *key, char *property, int argc, char *argv[]);


    void        (*cluster_reset_uptime)();

    int         (*cluster_is_node_up)(int node);


    void        (*cluster_send_nodata)(char *subject, u_short flags);

    void        (*cluster_send_nodata_to_node)(int node, char *subject, u_short flags);

    int         (*cluster_get_node_index)(void);


    int          (*cluster_should_assign_to_this_node)(char *to_assign);

    int         (*cluster_get_cluster_size)();
} cluster_interface_t;


#endif /* CLUSTER_H */