mdata_engine.h

Go to the documentation of this file.

#pragma once
#include "mdata_proto.h"
#include "mdata_aux.h"
#include <cache/xroad_objects.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
#define ANY_SOURCE xroad_str_null
 
typedef struct
{
   void* ctx;
   void (*on_subscribe_result)(mdata_subscribe_result_t*, void*);
   void (*on_feed_state)(mdata_feed_state_type_t, void*);
   void (*on_connected)(void*);
   void (*on_disconnected)(void*);
   void (*on_subscribe)(mdata_subscribe_t*, void*, void*);
} mdata_engine_callback_t;
 
typedef struct
{
   void* ctx;
   void (*on_mdata)(mdata_proto_type_t, void*, void*);
 
   void (*on_feed_state)(xroad_instr_t*, mdata_feed_state_type_t, void*);
 
} mdata_callback_t;
 
typedef struct mdata_engine_s mdata_engine_t;
 
mdata_engine_t* mdata_engine_create(xroad_xml_tag_t cfg, mdata_engine_callback_t ccb);
 
xroad_errno_t mdata_engine_start(mdata_engine_t* mdata);
 
void mdata_engine_stop(mdata_engine_t* mdata);
 
void mdata_engine_destroy(mdata_engine_t* mdata);
 
xroad_errno_t mdata_engine_put(mdata_engine_t* mdata, mdata_proto_type_t type, void* val);
 
xroad_errno_t mdata_engine_flush(mdata_engine_t* mdata);
xroad_errno_t mdata_engine_send(mdata_engine_t* mdata, mdata_proto_type_t type, void* val);
 
xroad_errno_t mdata_engine_subscribe(
      mdata_engine_t* mdata, xroad_instr_t* instr, mdata_subscription_mask_t mask, mdata_callback_t cb,
      xroad_str_t mdsource);
 
mdata_subscription_mask_t mdata_engine_get_mask(mdata_engine_t* mdata, xroad_instr_t* instr, mdata_callback_t cb);
 
/* *
 * deactivates mdata channels in case of issues wih mdata feed
 * @param[in] c - pointer to the mdata_engine_t instance
 * */
xroad_errno_t mdata_engine_deactivate(mdata_engine_t* c);
 
/* *
 * activates mdata channels
 * @param[in] c - pointer to the mdata_engine_t instance
 * */
xroad_errno_t mdata_engine_activate(mdata_engine_t* c);
 
/* *
 * Gets mdata feed state for instrument source 
 * @param[in] me - pointer to the mdata_engine_t instance
 * */
mdata_feed_state_type_t mdata_engine_get_feed_state(mdata_engine_t* me, xroad_instr_t* i, xroad_str_t mdsource);
 
#ifdef __cplusplus
}
#endif