mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-28 22:45:26 +08:00
c468481a36
* code optimize Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * add getTsMsgFromConsumerMsg Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * rename some variables for better readability Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * code optimize Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * code optimize Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * add chanWaitGroup Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * add chanTtMsgTime Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * rename lastTimeStamp to currTimeStamp Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * add comments Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * code optimize Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * support unsynced ttMsg Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * code optimize Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update testcase Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update testcase Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update testcase Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * add TestStream_PulsarTtMsgStream_3 Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * fix unittest Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * remove debug log Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * change ttMsg logic back Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * fix ci block issue Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * update testcase Signed-off-by: yudong.cai <yudong.cai@zilliz.com> * fix codacy Signed-off-by: yudong.cai <yudong.cai@zilliz.com>