Commit Graph

476 Commits

Author SHA1 Message Date
Xiangyu Wang
a2b8add4e2
[skip ci]Improve error message in mqclient (#10240)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-20 10:54:43 +08:00
Xiangyu Wang
1493aa1f65
[skip ci]Improve comments in mqclient (#10242)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-20 10:52:35 +08:00
yukun
81190c573a
[skip ci]Add comments for UpdateAckedInfo (#10213)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-19 20:34:50 +08:00
yukun
7c7a66df6d
[skip ci]Add comments for rocksmq Notify (#10212)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-19 20:32:48 +08:00
Xiangyu Wang
736a2cc358
[skip ci]Improve error message in rocksmq (#10196)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-19 17:54:37 +08:00
Xiangyu Wang
88a2b2b07c
[skip ci]Improve error message in rocksmq (#10195)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-19 17:52:42 +08:00
Xiangyu Wang
afa6eeecd7
[skip ci]Improve error message in rocksmq (#10194)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-19 17:50:49 +08:00
yukun
401753dea0
[skip ci]Add comments for rocksmq SeekToLatest (#10120)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-18 19:52:49 +08:00
yukun
ec667846f4
[skip ci]Add comments for rocksmq Seek (#10119)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-18 19:50:59 +08:00
yukun
8dccd0ca70
[skip ci]Add comments for rocksmq Consume (#10118)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-18 19:48:40 +08:00
yukun
65a1ae0210
[skip ci]Add comments for rocksmq produce (#10030)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-16 22:05:04 +08:00
yukun
e8d5a1ee5f
[skip ci]Add comments for DestroyConsumerGroup (#10029)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-16 22:03:09 +08:00
yukun
241acadce9
Remove error return when seek invalid messages in seekToLatest (#9967)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-16 21:49:40 +08:00
dragondriver
977e98d21b
[skip ci] Fix golint warning of paramtable (#9991)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-10-15 20:38:58 +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
Xiangyu Wang
f8c52dd5bb
Fix golint warning in indexparamcheck (#9947)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-15 20:23:16 +08:00
Xiangyu Wang
7ab109e57d
Fix golint warning in indexparamcheck (#9946)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-15 16:36:37 +08:00
yukun
2cfdf22897
Change retention ticker time to 10 minutes (#9933)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-15 15:44:35 +08:00
yukun
83f1b75293
[skip ci]Add comments for RegisterConsumer (#9912)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-14 20:02:37 +08:00
yukun
a0d9991d6f
[skip ci]Add comments for CreateConsumerGroup (#9911)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-14 20:00:35 +08:00
congqixia
6b8ff60de3
Close event channel when watch event found error (#9819)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2021-10-14 19:20:35 +08:00
congqixia
ec6e8e4127
Hide liveChn into sessionutil and fix liveness init order (#9860)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2021-10-14 16:40:35 +08:00
zhenshan.cao
bbafd05911
[skip ci]Fix golint error in paramtable (#9851)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
2021-10-14 14:04:34 +08:00
Xiangyu Wang
478daeaeea
Fix golint warnings in indexparamcheck (#9863)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-14 12:02:40 +08:00
Xiangyu Wang
274dd03a10
Fix golint warnings in indexparamcheck (#9861)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-14 11:52:40 +08:00
Xiangyu Wang
41bd393fe6
Fix golint warnings in indexparamcheck (#9862)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-10-14 11:30:39 +08:00
dragondriver
72d3d470ba
Use the server id as identifier in system topology graph (#9825)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-10-14 11:12:38 +08:00
yukun
d2e2e0a63c
[skip ci]Add comments for ExistConsumerGroup (#9832)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-13 20:44:33 +08:00
yukun
67d38d6cf1
Fix retention datarace (#9828)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-13 20:38:33 +08:00
zhenshan.cao
e97b62cf67
Change RocksDBLRUCache size to 0 (#9820)
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
2021-10-13 20:28:34 +08:00
dragondriver
395a122678
[skip ci] Fix golint warning of metric_type.go (#9829)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-10-13 20:14:33 +08:00
godchen
31c3942ca7
[skip ci]Fix mqclient producer fmt (#9774)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-10-13 12:44:33 +08:00
jingkl
66e8583f86
[skip ci] Add producer.go description (#8748)
Signed-off-by: jingkl <jingjing.jia@zilliz.com>
2021-10-13 11:14:39 +08:00
yukun
e3ce1696e7
[skip ci]Add comments for rocksmq DestroyTopic (#9735)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-12 19:37:20 +08:00
yukun
55c615b4e2
[skip ci]Add comments for rocksmq CreateTopic (#9733)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-12 19:33:24 +08:00
yukun
cdeb64d90a
Delete messages before delete meta data in rocksmq retention (#9694)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-12 19:09:22 +08:00
yukun
b6b4b784cc
Delete end key after rocksdb DeleteRange (#9572)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-10 21:50:33 +08:00
yukun
12b985c32e
Add resource free in err process (#9564)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 19:39:16 +08:00
dragondriver
6eb2fe6993
[skip ci] Fix go lint warning of hardware_info.go (#9589)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-10-09 19:35:02 +08:00
yukun
b6ec1783e4
Remove acked infos in memory for retention (#8735)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 17:24:55 +08:00
yukun
a6e97e0d44
Change LRUCache size of rocksdb to 512MB (#9509)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 11:08:56 +08:00
yukun
969c78e79d
[skip ci]Add comments for rocksmq close (#9519)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 00:11:36 +08:00
yukun
97a6bde82a
[skip ci]Add comments for StringToMsgID (#9518)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 00:07:52 +08:00
yukun
1ec153ad9b
[skip ci]Add comments for CreateProducer (#9517)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-09 00:03:51 +08:00
godchen
f4e0736e01
Handle util rocksmq returned error (#9169)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-10-08 19:07:21 +08:00
Xiaofan
fdbfa62b27
Add log for rocksmq (#8889)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-10-07 22:18:56 +08:00
dragondriver
057834fa57
[skip ci] Add desc comments for BaseConfAdapter (#9414)
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-10-07 22:10:42 +08:00
yukun
f89f2ded88
[skip ci]Add comments for rmq client subscribe (#9422)
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-10-07 21:21:05 +08:00
yukun
3dcfff3a70
[skip ci]Add comments for rmq client method (#9423)
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-10-07 21:18:52 +08:00
yukun
a4cffb7f1c
[skip ci]Add comments for rmqMessage (#9420)
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-10-07 21:10:55 +08:00