zhenshan.cao
|
6ae5b926c1
|
[skip ci]Fix golint error in mq_msgstream (#10860)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
|
2021-10-28 23:44:46 +08:00 |
|
Xiaofan
|
d845153de4
|
Add Buffer for consumer channel (#9578)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-10-15 20:31:16 +08:00 |
|
Xiaofan
|
a0b98dacda
|
Skip reconsume tt msgstream when datacoord restart (#9684)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-10-15 11:46:33 +08:00 |
|
xige-16
|
e99ecc8cab
|
Add ProduceMark interface to return messageID (#9556)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-10-11 11:38:57 +08:00 |
|
xige-16
|
593ceb6d1d
|
[skip ci] Add comment for seek (#8811)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-09-28 23:17:53 +08:00 |
|
xige-16
|
002e676bd1
|
[skip ci] Add comment for AsProducer (#8809)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-09-28 23:16:14 +08:00 |
|
xige-16
|
72e430614c
|
[skip ci] Add comment for AsConsumer (#8810)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-09-28 23:08:05 +08:00 |
|
congqixia
|
e7117f67ee
|
Add BroadcastMark for Msgstream returning MessageIDs (#8654)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-09-27 14:10:09 +08:00 |
|
Cai Yudong
|
ece0a06798
|
Update repack delete msg (#8631)
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-09-27 10:35:58 +08:00 |
|
congqixia
|
353eeab8b9
|
Add MessageID return value in producers (#8586)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-09-26 17:38:07 +08:00 |
|
Xiangyu Wang
|
cbe8c03224
|
Fix golint warnings in msg.go (#8590)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-26 17:36:07 +08:00 |
|
Cai Yudong
|
4fba738bec
|
Update internal proto DeleteRequest (#8466)
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-09-24 15:21:55 +08:00 |
|
Xiangyu Wang
|
eb413f1396
|
Add comments for exposed structures and functions (#8435)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-23 21:57:55 +08:00 |
|
Xiangyu Wang
|
57618ac624
|
Remove unused codes in msgstream (#8368)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-23 16:29:55 +08:00 |
|
Xiangyu Wang
|
f203f750aa
|
Improve import statements in msgstream (#8237)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-18 19:06:09 +08:00 |
|
congqixia
|
76f5264e79
|
Fix MqMsgStream Seek logic (#7536)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-09-07 16:35:59 +08:00 |
|
congqixia
|
d3027c0d28
|
Fix possible deadlock (#7428)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-09-02 14:56:10 +08:00 |
|
Xiaofan
|
aba234fa3f
|
Fix Msgstream exponential retry (#6807)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-08-03 10:39:24 +08:00 |
|
neza2017
|
a518e408b1
|
add log when seek in msgstream (#6244)
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
|
2021-07-01 13:46:16 +08:00 |
|
yukun
|
0f409da136
|
Fix standalone seek hang after restart (#6073)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-06-24 16:44:07 +08:00 |
|
xige-16
|
c310c70c00
|
Assign values to msgPack's startPosition in the form of deepCopy (#5900)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-06-21 14:16:03 +08:00 |
|
godchen
|
c2ecce61c0
|
Make pulsar client singleton (#5782)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-06-15 19:03:56 +08:00 |
|
neza2017
|
351d87055a
|
fix ttmsgstream (#5689)
* fix msgstream
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* fix asconsumer
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
|
2021-06-15 16:06:13 +08:00 |
|
bigsheeper
|
cdbc6d2c94
|
Refactor query node and query service (#5751)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
Co-authored-by: xige-16 <xi.ge@zilliz.com>
Co-authored-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-06-15 12:41:40 +08:00 |
|
godchen
|
918458a1be
|
Add msgstream seek (#5483)
* Add msgstream seek
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
* fix error
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
* change test name
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
* fix error
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
* remove file
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
* resolve conversation
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-05-31 17:46:30 +08:00 |
|
Cai Yudong
|
c468481a36
|
Optimize MqTtMsgStream and unittest (#5498)
* 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>
|
2021-05-31 11:31:30 +08:00 |
|
Cai Yudong
|
b414800d49
|
Update Seek interface (#5492)
* update Seek
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
* update Seek for mqTtMsgStream
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
* use Retry in Seek
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
* fix static-check
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-05-29 23:21:34 +08:00 |
|
xige-16
|
fce792b8bf
|
Add historical and streaming module in querynode (#5469)
* add historical and streaming
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
* fix GetSegmentInfo
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
* pass regression test
Signed-off-by: xige-16 <xi.ge@zilliz.com>
Co-authored-by: bigsheeper <yihao.dai@zilliz.com>
|
2021-05-28 10:26:30 +08:00 |
|
xige-16
|
3630eec92c
|
Fix receving wrong msg after seek (#5441)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-05-27 02:38:37 +00:00 |
|
zhenshan.cao
|
6766169878
|
Refactor repack logic for insertion (#5399)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
|
2021-05-25 11:53:15 +00:00 |
|
zhenshan.cao
|
3e73775cc1
|
Add ComputeProduceChannelIndexes for msgstream (#5364)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
|
2021-05-24 08:30:09 +00:00 |
|
Xiangyu Wang
|
82ccd4cec0
|
Rename module (#4988)
* Rename module
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-04-22 14:45:57 +08:00 |
|
xige-16
|
51b2b45e03
|
Add copyright for msgStream
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-04-19 11:30:19 +08:00 |
|
xige-16
|
78155d3959
|
Refactor load Release to async call in query service
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-04-15 15:15:46 +08:00 |
|
Xiangyu Wang
|
87a1e0b662
|
Reorganize msgstream
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-04-02 13:48:25 +08:00 |
|