Set sync type

Signed-off-by: neza2017 <yefu.chen@zilliz.com>
pull/4973/head^2
neza2017 2020-09-05 17:47:28 +08:00 committed by yefu.chen
parent a32cd72ba9
commit 559c160dd7
2 changed files with 5 additions and 2 deletions

4
.gitignore vendored
View File

@ -27,6 +27,10 @@ proxy/cmake_build
proxy/cmake-build-debug
proxy/thirdparty/grpc-src
proxy/thirdparty/grpc-build
proxy/milvus/
proxy/milvus/*
proxy/suvlim/
proxy/suvlim/*
# Compiled source
*.a

View File

@ -31,8 +31,7 @@ TimeSync::TimeSync(int64_t id,
for (;;) {
if (this->stop_) break;
this->sync_msg_.set_timestamp(this->timestamp_());
//TODO, set msg type
//this->sync_msg_.set_msgtype();
this->sync_msg_.set_sync_type(milvus::grpc::READ);
auto rst = producer.send(sync_msg_.SerializeAsString());
if (rst != pulsar::ResultOk) {
//TODO, add log