myvtm/Framework/RvcLogSdk/log_producer_config.h

#ifndef LOG_SDK_LOG_PRODUCER_CONFIG_H
#define LOG_SDK_LOG_PRODUCER_CONFIG_H

#include "log_define.h"
#include "log_producer_common.h"
#include <stdio.h>
#include <stddef.h>
#include <stdint.h>
#include "log_multi_thread.h"

LOG_CPP_START

#define MAX_TOKEN_LEN 256
typedef void (*Log_GetTokenCallBack)(char*, char*, char*, char*);

typedef struct _log_producer_config
{
    //守护上传：代替其他实体上传日志
    int enableGuarder;
    //天眼要求字段
    char* skyeyeServName;
    char* skyeyeCmptId;
    char* skyeyeCmptName;
    char* skyeyeTerminalNo;
    char* skyeyeVersion;
    char* skyeyeSn;
    char* skyeyeItem;
    char* skyeyeEntityName;
    //统一日志要求字段
    char* unitedAppName;
    char* unitedVersion;
    int unitedNeedArchived;
    char* unitedDeployUnitId;
    char* unitedServiceUnitId;

    char* endpoint;
    char* skyeye_user_topic;
    char* skyeye_sys_topic;
    char* beidou_topic;
    char* business_user_topic;
    char* business_sys_topic;
    char* vtmweb_topic;

    int32_t sendThreadCount;
    int32_t sendThreadWaitMs;

    int32_t logCountPerPackage;
    int32_t logBytesPerPackage;
    int32_t maxBufferBytes;

    int32_t connectTimeoutSec;
    int32_t sendTimeoutSec;
    int32_t destroyFlusherWaitTimeoutSec;
    int32_t destroySenderWaitTimeoutSec;

    int32_t compressType; // 0 no compress, 1 lz4
    int32_t ntpTimeOffset;
    int using_https; // 0 http, 1 https

    // for persistent feature
    int32_t usePersistent; // 0 no, 1 yes
    char* persistentFilePath;
    int32_t maxPersistentLogCount;
    int32_t usePersistentEncrypt; // 0 no, 1 yes
    char* PersistentEncryptPassword;
    int32_t openDB; // 0 no, 1 yes
    char debugMode;
    char useMemoryType;
    Log_GetTokenCallBack tokenFun;

}log_producer_config;

extern unsigned long g_upload_TerminalSys_Suc;
extern unsigned long g_upload_TerminalUser_Suc;
extern unsigned long g_upload_BussinessSys_Suc;
extern unsigned long g_upload_BussinessUser_Suc;
extern unsigned long g_upload_beidou_Suc;
extern unsigned long g_upload_TerminalSys_Err;
extern unsigned long g_upload_TerminalUser_Err;
extern unsigned long g_upload_BussinessSys_Err;
extern unsigned long g_upload_BussinessUser_Err;
extern unsigned long g_upload_beidou_Err;
extern unsigned long g_discardMsgNum_since_full;
extern unsigned long g_discardMsgNum_since_serverRet_RTI1002;
extern unsigned long g_notUploadLogNum;


/**
 * create a empty producer config, should set config params manually
 * @return empty producer config
 */
LOG_EXPORT log_producer_config* create_log_producer_config();

/**
 *  是否启用守护上传(代替其他实体上传日志)
 */
LOG_EXPORT void log_producer_config_set_enable_guard(log_producer_config* config, int enable);

/**
 *  设置getToken回调，一般只有send需要设置
 */
LOG_EXPORT void log_producer_config_set_tokenCallBack(log_producer_config* config, Log_GetTokenCallBack fun);

/**
 *  天眼日志必填要求字段：应用所在服务器名称
 */
LOG_EXPORT void log_producer_config_set_skyeye_servname(log_producer_config* config, char* servname);
/**
 *  天眼日志必填要求字段：当前应用的组件ID，为系统/子系统名（GroupId），如LA04、LA03.01。 只能用英文字符和数字，不能含下划线。
 */
LOG_EXPORT void log_producer_config_set_skyeye_cmptId(log_producer_config* config, char* cmptId);
/**
 *  天眼日志必填要求字段：当前应用的组件名称，为发布单元名（ArtifactId），可根据该发布单元功能自由定义，一般是模块名。只能用英文字符和数字。如Cmb_Netpay，APPSVRS_MobileHtml
 */
LOG_EXPORT void log_producer_config_set_skyeye_cmptname(log_producer_config* config, char* cmptname);
/**
 *  天眼日志必填要求字段：	终端号
 */
LOG_EXPORT void log_producer_config_set_skyeye_terminalNo(log_producer_config* config, char* terminalNo);
/**
 *  天眼日志必填要求字段：	日志版本号
 */
LOG_EXPORT void log_producer_config_set_skyeye_version(log_producer_config* config, char* version);
/**
 *  天眼日志必填要求字段：	终端UUID，终端唯一标识，例如：260ABB7100040505
 */
LOG_EXPORT void log_producer_config_set_skyeye_sn(log_producer_config* config, char* sn);
/**
 *  天眼日志必填要求字段：实体ID，例如:13
 */
LOG_EXPORT void log_producer_config_set_skyeye_item(log_producer_config* config, char* item);
/**
 *  天眼日志必填要求字段：实体名称,例如：SelfChecker
 */
LOG_EXPORT void log_producer_config_set_skyeye_entityname(log_producer_config* config, char* entityname);

LOG_EXPORT void log_producer_config_set_united_appname(log_producer_config* config, char* appname);
LOG_EXPORT void log_producer_config_set_united_version(log_producer_config* config, char* version);
LOG_EXPORT void log_producer_config_set_united_needArchived(log_producer_config* config, int needArchived);
LOG_EXPORT void log_producer_config_set_united_deployUnitId(log_producer_config* config, char* deployUnitId);
LOG_EXPORT void log_producer_config_set_united_serviceUnitId(log_producer_config* config, char* serviceUnitId);

LOG_EXPORT void log_producer_config_get_upload_info(unsigned long* t_upload_TerminalSys_Suc, unsigned long* t_upload_TerminalUser_Suc,
    unsigned long* t_upload_BussinessSys_Suc, unsigned long* t_upload_BussinessUser_Suc, unsigned long* t_upload_beidou_Suc,
    unsigned long* t_upload_TerminalSys_Err, unsigned long* t_upload_TerminalUser_Err,
    unsigned long* t_upload_BussinessSys_Err, unsigned long* t_upload_BussinessUser_Err, unsigned long* t_upload_beidou_Err);

LOG_EXPORT void log_producer_config_get_upload_info2(unsigned long* t_discard_full, unsigned long* t_discard_RTI1002, unsigned long* curLogNum);

typedef void (*dbg_callback)(const char*);
extern dbg_callback g_callback;
// 日志回调函数
LOG_EXPORT void log_producer_config_set_dbgFun(dbg_callback t_callback);

LOG_EXPORT void log_producer_config_set_send_thread_wait_ms(log_producer_config* config, int32_t ts);

/**
 * set producer config endpoint
 * @note if endpoint start with "https", then set using_https 1
 * @note strlen(endpoint) must >= 8
 * @param config
 * @param endpoint
 */
LOG_EXPORT void log_producer_config_set_endpoint(log_producer_config* config, const char* endpoint);

/**
 * default http, 0 http, 1 https
 * @param config
 * @param using_https
 */
LOG_EXPORT void log_producer_config_set_using_http(log_producer_config* config, int32_t using_https);

/**
 * set producer config topic
 * @param config
 * @param topic
 */
LOG_EXPORT void log_producer_config_set_skyeye_user_topic(log_producer_config* config, const char* topic);
LOG_EXPORT void log_producer_config_set_skyeye_sys_topic(log_producer_config* config, const char* topic);
LOG_EXPORT void log_producer_config_set_beidou_topic(log_producer_config* config, const char* topic);
LOG_EXPORT void log_producer_config_set_business_user_topic(log_producer_config* config, const char* topic);
LOG_EXPORT void log_producer_config_set_business_sys_topic(log_producer_config* config, const char* topic);
LOG_EXPORT void log_producer_config_set_vtmweb_topic(log_producer_config* config, const char* topic);

/**
 * set loggroup max log count, if loggoup's logs count  >= log_count, current loggroup will been flushed out
 * @param config
 * @param log_count
 */
LOG_EXPORT void log_producer_config_set_packet_log_count(log_producer_config* config, int32_t log_count);

/**
 * set loggroup max log bytes, if loggoup's log bytes  >= log_bytes, current loggroup will been flushed out
 * @param config
 * @param log_bytes
 */
LOG_EXPORT void log_producer_config_set_packet_log_bytes(log_producer_config* config, int32_t log_bytes);

/**
 * set max buffer size, if total buffer size > max_buffer_bytes, all send will fail immediately
 * @param config
 * @param max_buffer_bytes
 */
LOG_EXPORT void log_producer_config_set_max_buffer_limit(log_producer_config* config, int64_t max_buffer_bytes);

/**
 * set send thread count, default is 0.
 * @note if thread count is 0, flusher thread is in the charge of send logs.
 * @note if thread count > 1, then producer will create $(thread_count) threads to send logs.
 * @param config
 * @param thread_count
 */
LOG_EXPORT void log_producer_config_set_send_thread_count(log_producer_config* config, int32_t thread_count);


/**
 * set connect timeout seconds
 * @param config
 * @param connect_timeout_sec
 */
LOG_EXPORT void log_producer_config_set_connect_timeout_sec(log_producer_config* config, int32_t connect_timeout_sec);

/**
 * set send timeout seconds
 * @param config
 * @param send_timeout_sec
 */
LOG_EXPORT void log_producer_config_set_send_timeout_sec(log_producer_config* config, int32_t send_timeout_sec);

/**
 * set wait seconds when destroy flusher
 * @param config
 * @param destroy_flusher_wait_sec
 */
LOG_EXPORT void log_producer_config_set_destroy_flusher_wait_sec(log_producer_config* config, int32_t destroy_flusher_wait_sec);

/**
 * set wait seconds when destroy sender
 * @param config
 * @param destroy_sender_wait_sec
 */
LOG_EXPORT void log_producer_config_set_destroy_sender_wait_sec(log_producer_config* config, int32_t destroy_sender_wait_sec);

/**
 * set compress type, default 1 (lz4)
 * @param config
 * @param compress_type only support 1 or 0. 1 -> lz4, 0 -> no compress
 */
LOG_EXPORT void log_producer_config_set_compress_type(log_producer_config* config, int32_t compress_type);

/**
* set time offset between local time and server ntp time
* @param config
* @param ntp_time_diff
*/
LOG_EXPORT void log_producer_config_set_ntp_time_offset(log_producer_config* config, int32_t ntp_time_offset);

/**
 * set persistent flag, 0 disable, 1 enable
 * @param config
 * @param persistent
 */
LOG_EXPORT void log_producer_config_set_persistent(log_producer_config* config, int32_t persistent);

LOG_EXPORT void log_producer_config_set_persistent_encrypt(log_producer_config* config, int32_t enable);

LOG_EXPORT void log_producer_config_set_persistent_encrypt_password(log_producer_config* config, char* password);

LOG_EXPORT void log_producer_config_set_openDb(log_producer_config* config, int32_t openDB);

/**
 * set persistent file path
 * @param config
 * @param file_path full file path, eg : "app\\test\\data"
 * @note the file dir must exist
 */
LOG_EXPORT void log_producer_config_set_persistent_file_path(log_producer_config* config, const char* file_path);

/**
 * set max log count saved in disk
 * @param config
 * @param max_log_count
 */
LOG_EXPORT void log_producer_config_set_persistent_max_log_count(log_producer_config* config, int32_t max_log_count);

LOG_EXPORT void log_producer_config_switch_debug_mode(log_producer_config* config, int32_t switch_on);

/*
* param:memory_deal_type
0: open only
1: create if not exist and then open
2: create, if it has exists before, re-create and open it
*/
LOG_EXPORT void log_producer_config_memory_deal_type(log_producer_config* config, int32_t memory_deal_type);

/**
 * destroy config, this will free all memory allocated by this config
 * @param config
 */
LOG_EXPORT void destroy_log_producer_config(log_producer_config* config);



#ifdef LOG_PRODUCER_DEBUG
/**
 * print this config
 * @param config
 */
void log_producer_config_print(log_producer_config* config, FILE* pFile);

#endif

/**
 * check if given config is valid
 * @param config
 * @return 1 valid, 0 invalid
 */
LOG_EXPORT int log_producer_config_is_valid(log_producer_config* config);

/**
 *
 * @return
 */
LOG_EXPORT int log_producer_persistent_config_is_enabled(log_producer_config* config);

LOG_CPP_END
#endif