创建

1 files changed, 70 insertions, 0 deletions

diff --git a/include/doris_client.h b/include/doris_client.h
new file mode 100644
index 0000000..fea6826
--- /dev/null
+++ b/include/doris_client.h
@@ -0,0 +1,70 @@
+#ifndef __DORIS_CLIENT_H__
+#define __DORIS_CLIENT_H__
+
+#include <event.h>
+#include <cjson/cJSON.h>
+
+enum FSSTAT_DORIS_FILED_ITEMS
+{
+	DRS_FS_FILED_REQ_FAIL=0,
+	DRS_FS_FILED_REQ_META,
+	DRS_FS_FILED_RES_META,
+	DRS_FS_FILED_RES_NOMETA,
+	DRS_FS_FILED_REQ_FILES,
+	DRS_FS_FILED_RES_FILES,
+	DRS_FS_FILED_RES_FRAGS,
+	DRS_FS_FILED_RES_FRAGERR,
+	DRS_FS_FILED_RES_BYTES,
+	DRS_FS_FILED_RES_VERERR,
+
+	DRS_FS_FILED_BACKUP1_REQ,
+	DRS_FS_FILED_BACKUP2_REQ,
+	
+	FSSTAT_DORIS_FILED_NUM,
+};
+
+enum FSSTAT_DORIS_STATUS_ITEMS
+{
+	DRS_FS_STAT_MST_CNN_SRV=0,
+	DRS_FS_STAT_MST_FAIL_SRV,
+	DRS_FS_STAT_BCK1_CNN_SRV,
+	DRS_FS_STAT_BCK1_FAIL_SRV,
+	DRS_FS_STAT_BCK2_CNN_SRV,
+	DRS_FS_STAT_BCK2_FAIL_SRV,
+	DRS_FS_STAT_MEMORY_USED,
+	DRS_FS_STAT_HTTP_SESSIONS,
+
+	FSSTAT_DORIS_STATUS_NUM,
+};
+
+struct doris_statistics
+{
+	long long field[FSSTAT_DORIS_FILED_NUM];
+	long long status[FSSTAT_DORIS_STATUS_NUM];
+};
+
+struct doris_arguments
+{
+	int64_t current_version; //��ǰ�ѻ�ȡ��ϵ����°汾�ţ���������һ���汾ȡ����
+	int32_t businessid;
+	int32_t judian_id;
+};
+
+struct doris_instance;
+struct doris_callbacks
+{
+	void *userdata;
+	void (*version_start)(struct doris_instance *instance, cJSON *meta, void *userdata); //meta�������汾���������ڶ���Ч
+	void (*cfgfile_start)(struct doris_instance *instance, const char *tablename, size_t size, u_int32_t cfgnum, void *userdata);
+	void (*cfgfile_update)(struct doris_instance *instance, const char *data, size_t len, void *userdata);
+	void (*cfgfile_finish)(struct doris_instance *instance, void *userdata);
+	void (*version_error)(struct doris_instance *instance, void *userdata); //�����ļ�ʧ�ܣ��ð汾��Ҫ�ع�
+	void (*version_finish)(struct doris_instance *instance, void *userdata);
+};
+
+struct doris_parameter *doris_parameter_new(const char *confile, struct event_base *manage_evbase, struct doris_callbacks *cbs,
+	struct doris_arguments *args, void *runtimelog);
+struct doris_instance *doris_instance_new(struct doris_parameter *param, struct event_base *worker_evbase, void *runtimelog);
+
+#endif
+