data_lake_processor.h

Go to the documentation of this file.

#ifndef DATA_LAKE_PROCESSOR_H_
#define DATA_LAKE_PROCESSOR_H_

#include "mcl_core/mcl_http_client.h"
#include "data_lake_object.h"

typedef struct data_lake_processor_t
{
    char *access_token;                
    const char *client_id;             
    mcl_http_client_t *http_client;    
    char *upload_url_generation_url;   
} data_lake_processor_t;

mcl_error_t data_lake_processor_generate_upload_url(data_lake_processor_t *processor, data_lake_object_t* object, const char *subtenant_id);

mcl_error_t data_lake_processor_generate_upload_urls(data_lake_processor_t *processor, mcl_list_t *object_list, const char *subtenant_id);

mcl_error_t data_lake_processor_upload(data_lake_processor_t *processor, mcl_data_lake_object_t *object);

#endif //DATA_LAKE_PROCESSOR_H_