godchen
|
a1d1b3d0b6
|
Add reader interface (#11973)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-17 14:11:11 +08:00 |
|
Xiangyu Wang
|
12f50cb22c
|
[skip ci]Update OWNERS files (#11898)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-11-16 15:41:11 +08:00 |
|
congqixia
|
304bbd3e71
|
Add ConsumeAfterSeek interface (#11818)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-11-15 18:17:10 +08:00 |
|
godchen
|
639800241d
|
Make flow graph for delta channel (#11379)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-09 09:27:04 +08:00 |
|
bigsheeper
|
38375ee1d3
|
Add LoadBalance (#9945)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
|
2021-11-06 16:54:59 +08:00 |
|
Xiaofan
|
a4715996ef
|
Fix Pulsar seek to latest may block forever (#11128)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-11-05 14:55:44 +08:00 |
|
XuanYang-cn
|
d9ceb3b3ff
|
[skip ci]Update license for ms unmarshal (#11262)
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
|
2021-11-04 19:15:41 +08:00 |
|
XuanYang-cn
|
7a2877e2ab
|
[skip ci]Update license for ms msg (#11261)
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
|
2021-11-04 19:13:50 +08:00 |
|
XuanYang-cn
|
5b79c5ee92
|
[skip ci]Update license for ms mq (#11260)
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
|
2021-11-04 19:12:03 +08:00 |
|
XuanYang-cn
|
91be4b10cc
|
Make mq_msgstream_test log more infos (#11168)
See also: #11146
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
|
2021-11-04 15:58:17 +08:00 |
|
congqixia
|
9c53375bba
|
Fix MqttMsgStream skip current msg logic (#11171)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-11-03 17:11:47 +08:00 |
|
congqixia
|
be0daafdb0
|
Fix rocksmq SeekToLatest (#11029)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-11-01 19:35:51 +08:00 |
|
groot
|
e0a2bf336d
|
[skip ci] Typo (#10888)
Signed-off-by: yhmo <yihua.mo@zilliz.com>
|
2021-10-29 12:07:20 +08:00 |
|
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 |
|
xige-16
|
0cedd9d47e
|
Compaction multiSegmentChangeInfo to a single info (#10587)
Signed-off-by: xige-16 <xi.ge@zilliz.com>
|
2021-10-26 15:18:22 +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 |
|
yukun
|
92815f4542
|
Change timestamp to timestamps in internalproto.DeleteRequest (#9802)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-10-14 14:48:34 +08:00 |
|
bigsheeper
|
d567b21fd4
|
Add globalSegmentManager and consume changeInfoMsg (#9575)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
|
2021-10-11 15:40:38 +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 |
|
bigsheeper
|
3a4df03b70
|
Add SealedSegmentsChangeInfo and changeInfoMsg (#9479)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
|
2021-10-09 14:45:00 +08:00 |
|
Xiangyu Wang
|
d6f96ec9fc
|
Add unit tests for mq_msgstream.go (#8812)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-29 09:54:04 +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 |
|
Xiangyu Wang
|
f6632acc4c
|
Add unit tests for mq_msgstream.go (#8792)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-28 22:02:15 +08:00 |
|
Xiangyu Wang
|
99b022fc4e
|
Clear golint warning in msgstream (#8722)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-27 23:52:02 +08:00 |
|
Cai Yudong
|
6ab00add27
|
Change expr_plan to primary_keys in internal proto DeleteRequest (#8655)
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-09-27 14:17:58 +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
|
31590bde2c
|
Rename ChannelID to ShardName to fix build fail (#8646)
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
|
2021-09-27 11:27:30 +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 |
|
zhenshan.cao
|
b71bffe26f
|
Replace ChannelID with ShardName in DML Request (#8539)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
|
2021-09-27 10:01:59 +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 |
|
Xiangyu Wang
|
cd980dd13b
|
Add unit test for mq_msgstream.go (#8548)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-26 13:09:56 +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
|
884d0d672e
|
Improve unit test in mq_msgstream.go (#8427)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-23 20:07:55 +08:00 |
|
godchen
|
3c8f031968
|
[skip ci]Add msgstream trace comment (#8349)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-09-23 17:11:54 +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 |
|
Xiangyu Wang
|
32c6033f4a
|
Add unit tests for msg.go (#8227)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-18 19:04:04 +08:00 |
|
Xiangyu Wang
|
c314b2b4a8
|
Remove unused label rules (#7929)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-18 18:19:51 +08:00 |
|
Xiangyu Wang
|
8b21a4b596
|
Add unit tests for msg.go (#8150)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-17 23:55:50 +08:00 |
|
Xiangyu Wang
|
b7b28abd77
|
Remove mem_msgstream that is no longer needed (#8155)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-17 18:43:54 +08:00 |
|
Xiangyu Wang
|
422b7dcf3e
|
Add unit tests for mq_factory (#8140)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-17 16:23:51 +08:00 |
|
Xiaofan
|
d6f0c5069f
|
[skip ci] Add comments for memory message queue (#8018)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-09-16 23:41:49 +08:00 |
|
Xiangyu Wang
|
0aa65f559a
|
Rename unit tests to meet new naming conventions (#8017)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-15 23:11:49 +08:00 |
|
congqixia
|
98732b3d43
|
Remove duplicated code in msgs (#7801)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-09-14 17:07:48 +08:00 |
|
Xiangyu Wang
|
60c11c85ad
|
[skip ci]Rename unit tests (#7844)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-09-13 21:24:58 +08:00 |
|