connectivity_processor.h

Go to the documentation of this file.

#ifndef CONNECTIVITY_PROCESSOR_H_
#define CONNECTIVITY_PROCESSOR_H_

#include "mcl_core/mcl_http_client.h"
#include "connectivity_configuration.h"
#include "store.h"
#include "mapping.h"
#include "data_source_configuration.h"

typedef struct connectivity_processor_t
{
    const char *agent_id;
    const char *hostname;
    char *access_token;
    char *exchange_url;
    char *mapping_url;
    mcl_http_client_t *http_client;
    mcl_size_t max_http_payload_size;
} connectivity_processor_t;

MCL_LOCAL mcl_error_t connectivity_processor_initialize(connectivity_configuration_t *configuration, connectivity_processor_t **processor);

MCL_LOCAL mcl_error_t connectivity_processor_exchange(connectivity_processor_t *connectivity_processor, mcl_item_t *item);

MCL_LOCAL mcl_error_t connectivity_processor_create_mapping(connectivity_processor_t *connectivity_processor, mapping_t *mapping);

MCL_LOCAL mcl_error_t connectivity_processor_get_data_source_configuration(connectivity_processor_t *connectivity_processor,
    data_source_configuration_t **configuration);

MCL_LOCAL void connectivity_processor_destroy(connectivity_processor_t **processor);

#endif //CONNECTIVITY_PROCESSOR_H_