myvtm/Framework/RvcLogSdk/log_producer_sender.h

#ifndef LOG_C_SDK_LOG_PRODUCER_SENDER_H
#define LOG_C_SDK_LOG_PRODUCER_SENDER_H


#include "log_define.h"
#include "log_producer_config.h"
#include "log_builder.h"
LOG_CPP_START

#define LOG_PRODUCER_SEND_MAGIC_NUM 0x1B35487A

typedef int32_t log_producer_send_result;

#define LOG_SEND_OK 0
#define LOG_SEND_NETWORK_ERROR 1
#define LOG_SEND_QUOTA_EXCEED 2
#define LOG_SEND_UNAUTHORIZED 3
#define LOG_SEND_SERVER_ERROR 4
#define LOG_SEND_DISCARD_ERROR 5
#define LOG_SEND_TIME_ERROR 6

#define LOG_HTTP_ERRPARAM 300

extern const char* LOGE_SERVER_BUSY;//= "ServerBusy";
extern const char* LOGE_INTERNAL_SERVER_ERROR;//= "InternalServerError";
extern const char* LOGE_UNAUTHORIZED;//= "Unauthorized";
extern const char* LOGE_WRITE_QUOTA_EXCEED;//="WriteQuotaExceed";
extern const char* LOGE_SHARD_WRITE_QUOTA_EXCEED;//= "ShardWriteQuotaExceed";
extern const char* LOGE_TIME_EXPIRED;//= "RequestTimeExpired";


typedef struct _log_producer_send_param
{
    log_producer_config * producer_config;
    void * producer_manager;
    lz4_log_buf* log_buf;
    uint32_t magic_num;
    uint32_t builder_time;
}log_producer_send_param;

extern void * log_producer_send_fun(void * send_param);

extern log_producer_result log_producer_send_data(log_producer_send_param * send_param);

extern log_producer_send_result AosStatusToResult(post_log_result * result);

extern log_producer_send_param * create_log_producer_send_param(log_producer_config * producer_config,
                                                                void * producer_manager,
                                                                lz4_log_buf* log_buf,
                                                                log_group_builder * builder);

//extern void send_log_data(const char* url, const char* body);

LOG_CPP_END

#endif //LOG_C_SDK_LOG_PRODUCER_SENDER_H