milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
11,991 Commits
142 Branches
117 Tags
569 MiB
Commit Graph

178 Commits (694e3f72a10f6dbad8100c4786178c016ef1726b)

Author SHA1 Message Date
yukun 847d3e7d4a
Break page loop when no acked ts is nil (#12705) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-06 15:17:35 +08:00
yukun 5702494efe
[skip ci]Add comment for rocksmq reader (#12731) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-03 20:33:50 +08:00
yukun a1ab961e49
[skip ci]Add comment for rocksmq reader (#12730) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-03 20:31:54 +08:00
yukun 764cf1a53e
Add rocksmq server close when standalone exit (#12255) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-02 10:27:32 +08:00
congqixia 73705333b4
Fix zero length slice declaration in rocksmq_impl.go (#12577) 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
 2021-12-01 23:45:32 +08:00
yukun 777dd95071
[skip ci]Add comment for rocksmq reader (#12570) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-01 22:37:42 +08:00
yukun fa4372a597
[skip ci]Add comment for rocksmq reader (#12569) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-12-01 22:35:47 +08:00
yukun fea1126946
[skip ci]Fix golint (#12481) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-30 19:43:46 +08:00
congqixia 4dd3dc7aa9
Improve rocksmq CreateConsumerGroup log (#12473) 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
 2021-11-30 19:09:33 +08:00
yukun 47f1f51bca
[skip ci]Add comment for rocksmq reader (#12403) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-29 23:59:53 +08:00
shaoyue f796bce1ed
[skip ci] Fix golint for rocketsmq_impl.go (#12363) 
Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
 2021-11-29 23:15:41 +08:00
yukun 9ae7e19b82
[skip ci]Add comment for rocksmq reader seek (#12405) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-29 21:10:01 +08:00
godchen 8cd1fccfb1
Return rocksdb reader timeout error (#12317) 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
 2021-11-29 13:27:17 +08:00
yukun 080eaa9a5c
Add isClosed for rocksmq (#12267) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-26 11:27:16 +08:00
godchen e3f49858c5
Add subscription prefix (#12251) 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
 2021-11-24 17:47:15 +08:00
Xiaofan 0aaa87a79a
Fix MsgStream inconsistent seek (#12042) 
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
 2021-11-24 10:25:15 +08:00
yukun 6a167f8579
Fix rocksmq produce hang when do search repeatedly (#12225) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-23 19:15:22 +08:00
yukun 835451e331
Update rocksmq consume slowly log (#12179) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-22 18:51:14 +08:00
yukun f5bb180adb
Support multiple readers on one topic (#12155) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-22 10:35:14 +08:00
yukun ac175b6f00
Add rocksmq produce slowly hint log (#12156) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-21 15:33:13 +08:00
yukun 2147507e89
Add reader implementation in rocksmq (#12137) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-20 20:57:13 +08:00
yukun 8c947109a9
Add log in rocksmq (#12138) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-20 00:11:13 +08:00
shaoyue 888aad120c
[skip ci] Fix comment typo (#12122) 
Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
 2021-11-19 17:59:39 +08:00
yukun d482f8aa9f
[skip ci]Add license in reader.go (#12032) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-17 21:59:38 +08:00
godchen a1d1b3d0b6
Add reader interface (#11973) 
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
 2021-11-17 14:11:11 +08:00
yukun 79fc84f3db
Optimize updatePageInfo in rocksmq (#11711) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-16 17:13:10 +08:00
yukun da9228ab37
Add topic lock for DestroyTopic (#11786) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-16 17:07:10 +08:00
yukun 897d6b5fc8
Check rmq retention only by page (#11508) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-16 14:49:11 +08:00
Xiangyu Wang f26ab5c29a
[skip ci]Improve import statements (#11635) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-15 19:24:52 +08:00
yukun f51ef71b51
Change default retentionSizeInMB to 8192(8GB) (#11436) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-11 17:18:43 +08:00
Xiangyu Wang 47ff1a45fe
Improve log messages in rocksmq (#11230) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-10 22:10:47 +08:00
yukun 4c6d77201f
[skip ci]Add rmq consumer impl getExistedConsumer comment (#11594) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-10 21:50:45 +08:00
yukun 9bc7393913
[skip ci]Add rmq consumer impl Subscription comment (#11593) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-10 21:48:53 +08:00
yukun 1e86bd3038
[skip ci]Add rmq consumer impl topic comment (#11533) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-10 19:21:44 +08:00
yukun 5ec895fedc
[skip ci]Add rmq consumer impl MsgMutex comment (#11532) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-09 21:13:37 +08:00
yukun 2073ae497b
[skip ci]Add rmq consumer impl chan comment (#11531) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-09 21:11:41 +08:00
yukun 11e6a8ea50
[skip ci]Add rmq_client comment (#11458) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-08 21:09:07 +08:00
congqixia 6d3952c9bf
Fix msgs consumed before seek appear in output after seek (#11419) 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
 2021-11-08 20:57:57 +08:00
congqixia d50543a030
Batch consume msg in rockmq internal loop (#11373) 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
 2021-11-08 20:56:07 +08:00
yukun dfbb4c33b4
Rename newExpiredCleanUp to expiredCleanUp (#11433) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-08 19:25:00 +08:00
yukun 3a65a4517c
[skip ci]Add retention comment (#11432) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-08 18:45:14 +08:00
yukun 8ec040a35c
Add rocksmqPageSize to config (#11113) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-08 10:17:18 +08:00
yukun 425c7e09d4
[skip ci]Add rmq retention comment (#11344) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-05 21:53:22 +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
Xiangyu Wang 60848029e1
Improve warning message in rocksmq (#11227) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-05 10:58:55 +08:00
yukun c05ed4c365
[skip ci]Add rmq_imple seek comments (#11273) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-04 20:51:10 +08:00
Xiangyu Wang e8c858b545
Improve error message in util (#11137) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-04 13:36:35 +08:00
Xiangyu Wang 508f560527
Improve error message in util (#11135) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-04 13:34:45 +08:00
Xiangyu Wang cc6a08f097
Improve error message in util (#11136) 
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
 2021-11-04 13:32:46 +08:00
yukun 82e5d21317
Fix MB const size (#11088) 
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
 2021-11-02 18:06:28 +08:00