Xiangyu Wang
ad09fb70ba
[skip ci]Improve import statements ( #11634 )
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-11-15 19:22:45 +08:00
Xiangyu Wang
537e302e22
[skip ci]Improve import statements ( #11633 )
...
Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
2021-11-15 19:20:34 +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
Xiaofan
71e814f796
Remove common.yaml and component.yaml ( #11661 )
...
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-11-12 21:25:08 +08:00
Xiaofan
3cd47cd89e
Remove common.yaml and component.yaml ( #11662 )
...
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-11-12 18:53:11 +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
Xiaofan
5f08b67156
Move node.yaml to component.yaml ( #11363 )
...
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-11-10 14:27:37 +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
2c215a0be3
[skip ci]Add rmq_producer comment ( #11346 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-05 21:59:10 +08:00
yukun
ab00fe90de
[skip ci]Add rmq_producer comment ( #11345 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-05 21:57:21 +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
zhenshan.cao
9885838593
Add extra methods to convert between uint64 and big-endian bytes slice ( #11338 )
...
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
2021-11-05 19:10: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
godchen
9bf68ac3eb
Fix timestamp endian error ( #11220 )
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-11-05 13:56:58 +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
bigsheeper
c99d1a56bf
Refactor proxy ticker to fix guarantee_time not work ( #11248 )
...
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2021-11-05 09:14:02 +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
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
yukun
eda65381c2
[skip ci]Add rmq producer comments ( #11272 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-04 20:45:17 +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
xige-16
b567a8e5b5
Add SystemInfo msgType for getMetricRequest ( #11151 )
...
Signed-off-by: xige-16 <xi.ge@zilliz.com>
2021-11-04 10:58:11 +08:00
yukun
e817cfbae6
[skip ci]Add pulsar client comments ( #11197 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-03 23:20:46 +08:00
congqixia
dddf84b194
Add unit test for pulsarClient Seek ( #11107 )
...
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2021-11-03 16:34:12 +08:00
zhenshan.cao
b768fb2e07
[skip ci]Fix golint error in indexparamcheck ( #11046 )
...
Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
2021-11-02 21:18:55 +08:00
dragondriver
7f00753074
[skip ci] Fix golint warning of time.go ( #11025 )
...
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-11-02 21:05:45 +08:00
godchen
a0a3a889e7
Add common endian for global use ( #11092 )
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-11-02 18:16:32 +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
yukun
ea6cd7d27c
Move topic lock to the front of final delete in retention expired cleanup ( #11076 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-02 17:28:31 +08:00
yukun
a8722797fe
Add topic lock for rocksmq Seek ( #11083 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-02 17:00:31 +08:00
Xiaofan
ca56290e85
Fix rocksdb retention ts not set ( #11081 )
...
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-11-02 16:50:31 +08:00
Ji Bin
c63b804606
Windows dummy metrics for container. ( #10625 )
...
In windows we do not have cgroups.
This changes for return a dummy metrics under windows.
Signed-off-by: Ji Bin <matrixji@live.com>
2021-11-02 16:36:31 +08:00
congqixia
7d671b14ff
Fix SeekToLatest memory leakage and remove redundant logic ( #11057 )
...
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2021-11-02 14:14:40 +08:00
yukun
af7a5ca50f
[skip ci]Add rocksmq client comments ( #11052 )
...
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-11-01 23:02:33 +08:00
dragondriver
66c255c02e
[skip ci] Fix golint warning of conf_adapter_mgr.go ( #11026 )
...
Signed-off-by: dragondriver <jiquan.long@zilliz.com>
2021-11-01 22:43:48 +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
XuanYang-cn
ca857d922c
Fix session util using the same context ( #10981 )
...
Before this PR, session_util used the same context for new session,
keepalive check, and etcd keep alive. So if we cancel this context
by ourselves, half the chances will the etcd keep-alive-channel be
closed by etcd, which will make session utils `think` there's something
wrong in connecting to etcd, and half the chances will our keepalive check
exit as expected.
To solve this problem, this PR seperates 2 contexts: etcd keep alive
channel context and our liveness check context. So that when we cancel
this liveness check context, session util will exit as expected.
Resolves : #10881
Signed-off-by: yangxuan <xuan.yang@zilliz.com>
2021-11-01 18:25:58 +08:00
groot
a6160bc79e
[skip ci] Add comment ( #10991 )
...
Signed-off-by: yhmo <yihua.mo@zilliz.com>
2021-11-01 15:48:02 +08:00