summaryrefslogtreecommitdiff
path: root/server/doris_server_main.h
diff options
context:
space:
mode:
Diffstat (limited to 'server/doris_server_main.h')
-rw-r--r--server/doris_server_main.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/server/doris_server_main.h b/server/doris_server_main.h
index b97f760..ea348b9 100644
--- a/server/doris_server_main.h
+++ b/server/doris_server_main.h
@@ -20,6 +20,7 @@
#include "doris_consumer_client.h"
#include "doris_server_receive.h"
+#include "doris_server_kvdb.h"
#include <map>
#include <string>
@@ -48,9 +49,10 @@ struct doris_business
/*first for configuration*/
char bizname[32];
u_int32_t recv_way;
- u_int32_t cache_max_versions;
+ int32_t cache_max_versions;
u_int32_t concurrency_allowed;
u_int32_t saves_when_fulldel; //��ȫ������ʱ����ౣ�漸�����µ�ȫ���汾��0-ȫ����
+ u_int32_t persistence_write_on;
char recv_path_full[256];
char recv_path_inc[256];
char store_path_root[256];
@@ -74,6 +76,7 @@ struct doris_business
struct doris_prod_instance *instance;
map<string, struct version_list_node *> *token2node;
int64_t version;
+ int64_t genversion_seq; //postģʽ���������ɰ汾�ŵ�����
int32_t source_from;
int32_t type;
int64_t version_cfgnum;
@@ -117,12 +120,14 @@ struct doris_global_info
u_int32_t business_num;
u_int32_t business_post_num; //postģʽ�м���
int32_t business_post_ups; //�����˼���
+ int32_t business_post_nopersists;
int32_t mmid_post_server; //value=PROMETHUES_POST_*
map<string, struct doris_business*> *name2business;
map<string, struct doris_csum_param *> *confile2csmparam;
struct MESA_MonitorHandler *monitor;
pthread_mutex_t mutex_lock;
+ struct doris_kvhandle *kvdbhandle;
/*logs*/
u_int32_t log_level;