src/ntc_http_collect.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

#ifndef NTC_HTTP_COLLECT_H
#define NTC_HTTP_COLLECT_H


#include "stream.h"

typedef struct _g_http_url_discovery_item
{

	int reorder_num;

	unsigned int hash_size;
	unsigned int expire_time;

    char topic_buf[64];
    char local_ip_str[128];
    unsigned int local_ip_nr;

	unsigned int enable_lostlen;
	unsigned int enable_double;
	unsigned int enable_filter;
	unsigned int enable_stat;
	unsigned int stat_interval;		
	char stat_path[1024];
	void *field_handle;

	int fs_drop_num_id;
	int fs_err_num_id;

	int fs_single_url_num_id;
	int fs_double_url_num_id;
	int fs_s2c_http_num_id;
	int fs_lost_num_id;
	int fs_c2s_nourl_num_id;
	int fs_double_nourl_num_id;

    int fs_filter_num_id;
	int fs_url_num_id;
	int fs_url_len_id;
	int fs_refer_num_id;
	int fs_refer_len_id;

    int kafka_mode;

	void * log_handle;
	unsigned int log_level;
	char log_path[1024];
	char profile_path[1024];
	char filter_file_path[1024];
	char kafka_brokelist[1024];
	char kafka_handle_provide_path[1024];
	char kafka_handle_name[1024];
}g_http_url_discovery_item;


#ifdef __cplusplus
extern "C"
{
#endif
	int HTTP_URL_DISCOVERY_INIT();
	void  HTTP_URL_DISCOVERY_DESTROY();


#ifdef __cplusplus
}
#endif

#endif