dataproxy-sdk cpp version, used for sending data to dataproxy
Go to the dataproxy-sdk-cpp root, and run
./build.sh
Refer to release/conf/config_example.json.
| name | default value | description |
|---|---|---|
| thread_num | 10 | number of network sending threads |
| inlong_group_ids | "" | the list of inlong_group_id, seperated by commas, such as “b_inlong_group_test_01, b_inlong_group_test_02” |
| enable_groupId_isolation | false | whether different groupid data using different buffer pools inside the sdk |
| buffer_num_per_groupId | 5 | number of buffer pools of each groupid |
| enable_pack | true | whether multiple messages are packed while sending to dataproxy |
| pack_size | 4096 | byte, pack messages and send to dataproxy when the data in buffer pool exceeds this value |
| ext_pack_size | 16384 | byte, maximum length of a message |
| enable_zip | true | whether zip data while sending to dataproxy |
| min_ziplen | 512 | byte, minimum zip len |
| enable_retry | true | whether do resend while failed to send data |
| retry_ms | 3000 | millisecond, resend interval |
| retry_num | 3 | maximum resend times |
| max_active_proxy | 3 | maximum number of established connections with dataproxy |
| max_buf_pool | 50 *1024* 1024 | byte, the size of buffer pool |
| log_num | 10 | maximum number of log files |
| log_size | 10 | MB, maximum size of one log file |
| log_level | 2 | log level: trace(4)>debug(3)>info(2)>warn(1)>error(0) |
| log_file_type | 2 | type of log output: 2->file, 1->console |
| log_path | ./logs/ | log path |
| proxy_update_interval | 10 | interval of requesting and updating dataproxy lists from manager |
| proxy_cfg_preurl | “http://127.0.0.1:8099/inlong/manager/openapi/dataproxy/getIpList” | the url of manager openapi |
| need_auth | false | whether need authentication while interacting with manager |
| auth_id | "" | authenticate id if need authentication |
| auth_key | "" | authenticate key if need authentication |
int32_t tc_api_init(const char* config_file). Here, config_file is the path of your config file, and absolute path is recommended. Note that only once called is needed in one process.int32_t tc_api_init(ClientConfig& client_config). Here, client_config is the pointer of a ClientConfig object.Then, send data: int32_t tc_api_send(const char* inlong_group_id, const char* inlong_stream_id, const char* msg, int32_t msg_len, UserCallBack call_back = NULL). If you set call_back, it will be callbacked if your data failed to send. See the signature of UserCallBack in release/inc/user_msg.h.
Finally, close sdk if no more data to be sent: int32_t tc_api_close(int32_t max_waitms). Here, max_waitms is the interval of waiting data in memory to be sent.
Note, the above functions return 0 if success, otherwise it means failure. As for other return results, please refer to SDKInvalidResult in release/inc/tc_api.h.
Refer to release/demo/send_demo.cc.
Static lib is in release/lib. Header file is in release/inc.