Commit Graph

268 Commits

Author SHA1 Message Date
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
Xiangyu Wang
494600c37c
Add unit tests for msg.go (#7691)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-10 14:24:02 +08:00
Xiangyu Wang
6b86a18a7e
Comments unused msg from msg.go (#7686)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-10 11:12:05 +08:00
Xiangyu Wang
42aafdc407
Remove unused msg from msg.go (#7612)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-09 19:56:00 +08:00
Xiangyu Wang
624ea2f676
Add unit tests for msg.go (#7659)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-09 19:03:40 +08:00
dragondriver
9b21b3b5fd
Initialize test framework of proxy (#7563)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-09-09 10:06:29 +08:00
Xiangyu Wang
2224099f22
Add unit tests for msg.go (#7577)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-08 16:54:00 +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
Xiangyu Wang
79a0a5482f
Add unit test for mq_factory (#7477)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-09-06 14:59:21 +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
yukun
847586eb95
Add rocksmq retention (#6617)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-08-16 18:46:10 +08:00
XuanYang-cn
6c5be83ea1
Refactor NewEtcdKV API (#7075)
This PR mainly did the following 3 things:

- Refactor NewEtcdKV API
- Add unittests for `kv/etcd/`, raise the coverage
up to 94%
- Correct some APIs from version to revision

The old NewEtcdKV() API took `clientv3.Client` as
one of the input, making everyone who using this API
had to create a new `clientv3.Client`. So there're a lot
of repeated codes everywhere.

Meanwhile, someplace didn't even check whether the
`clientv3.New()` returned error or not, and the old API
also didn't check whether the clientv3.Client was Nil.
This caused issue#6955.

Ectd's version and revision have nothing alike, they
represent different concepts, but our APIs kind of
mixed them all up. So I correct those APIs' names.

Resolves: #6955

Signed-off-by: yangxuan <xuan.yang@zilliz.com>
2021-08-13 11:04:09 +08:00