yukun
|
9a8f53fb5f
|
[skip e2e]Add comment for rocksmq client (#14115)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-24 10:47:56 +08:00 |
yukun
|
2fc6db7973
|
[skip e2e]Add comment for rmq create reader (#13639)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 22:42:42 +08:00 |
godchen
|
e3f49858c5
|
Add subscription prefix (#12251)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-24 17:47:15 +08:00 |
godchen
|
116a503b4a
|
From dml cp load delete msg (#12144)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-21 07:33:14 +08:00 |
godchen
|
51b353b52c
|
Add msgstream reader (#12130)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-19 15:57:12 +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
|
872f6f8a04
|
[skip ci]Add rmq client comments (#11271)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-04 20:49:20 +08:00 |
Xiangyu Wang
|
cd6a4a6704
|
[skip ci]Improve error message in mqclient (#10241)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-10-20 10:56:35 +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 |
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 |
Xiangyu Wang
|
b6617a295a
|
[skip ci]Fix golint warnings in mqclient (#9239)
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-10-04 23:48:10 +08:00 |
yukun
|
c486007796
|
Rocksmq support SubscriptionPositionLatest (#8947)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-09-30 20:51:40 +08:00 |
yukun
|
06c9f03c59
|
Refactor rocksmq close logic and improve codecov (#8278)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-09-22 17:21:00 +08:00 |
godchen
|
3c2821e5e2
|
Add rmq consumer close (#7596)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-09-08 21:49:59 +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 |
godchen
|
91ef35bad4
|
Change receive msg logic (#5605)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-06-15 16:04:48 +08: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 |
Xiangyu Wang
|
c731e2df78
|
Add license header in util
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-04-19 13:42:47 +08:00 |
Xiangyu Wang
|
8b62790017
|
Reorganize mqclient
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
|
2021-04-02 10:01:11 +08:00 |