summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
author[email protected] <[email protected]>2021-09-08 10:45:47 +0800
committer[email protected] <[email protected]>2021-09-08 10:45:47 +0800
commit6922e3dd5040b8e1cb88a5f2f96d2a5fb8824e71 (patch)
tree609c2be54a364a810e3d4306643c41fa796f72aa /include
parent6386e5de579c42f2730e0c92b8e4cab5b6c57559 (diff)
支持以业务为单位,配置文件不持久化到本地HEADmaster
Diffstat (limited to 'include')
-rw-r--r--include/doris_consumer_client.h4
1 files changed, 2 insertions, 2 deletions
diff --git a/include/doris_consumer_client.h b/include/doris_consumer_client.h
index f772626..4150708 100644
--- a/include/doris_consumer_client.h
+++ b/include/doris_consumer_client.h
@@ -46,7 +46,7 @@ struct doris_csum_statistics
struct doris_arguments
{
char bizname[32];
- int64_t current_version; //��ǰ�ѻ�ȡ��ϵ����°汾�ţ���������һ���汾ȡ����
+ int64_t current_version; //��ǰ�ѻ�ȡ��ϵ����°汾�ţ���������һ���汾ȡ����; ������ʾ��ȡ���µ�N���汾��
int32_t judian_id;
};
@@ -70,7 +70,7 @@ struct doris_callbacks
void (*cfgfile_finish)(struct doris_csum_instance *instance, const char *md5, void *userdata);
void (*version_error)(struct doris_csum_instance *instance, void *userdata); //�����ļ�ʧ�ܣ��ð汾��Ҫ�ع�
void (*version_finish)(struct doris_csum_instance *instance, void *userdata);
- void (*version_updated)(struct doris_csum_instance *instance, void *userdata); //��ʱû��������
+ void (*version_updated)(struct doris_csum_instance *instance, int64_t lastest_version, void *userdata); //��ʱû��������
};
struct doris_csum_param *doris_csum_parameter_new(const char *confile, struct event_base *manage_evbase, void *runtimelog);