Xiaofan
0aaa87a79a
Fix MsgStream inconsistent seek ( #12042 )
...
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-11-24 10:25:15 +08:00
godchen
a1d1b3d0b6
Add reader interface ( #11973 )
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-11-17 14:11:11 +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
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
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
groot
6168c0b9c7
Reduce go unittest time cost ( #8555 )
...
Signed-off-by: yhmo <yihua.mo@zilliz.com>
2021-09-26 12:42:14 +08:00
groot
618fef0a43
Add unittest for mqclient ( #7578 )
...
Signed-off-by: yhmo <yihua.mo@zilliz.com>
2021-09-08 16:52:35 +08:00
godchen
c2ecce61c0
Make pulsar client singleton ( #5782 )
...
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
2021-06-15 19:03:56 +08:00
neza2017
ac9dde7352
fix seek on pulsar msgstream ( #5726 )
...
* fix seek on pulsar msgstream
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* test seek on pulsar msgstream
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* msg-seek test test
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
* add pure pulsar client seek test
Signed-off-by: yefu.chen <yefu.chen@zilliz.com>
2021-06-15 16:14:29 +08:00
XuanYang-cn
9151e13480
Remove not using dependence and proto ( #5226 )
...
- FlushMsg proto message is no longer in use
- We don't depend on "github.com/prometheus/common/log"
Signed-off-by: yangxuan xuan.yang@zilliz.com
2021-05-14 08:50:55 +00:00
Cai Yudong
6f3a460b4e
Add pulsar seek example in pulsar_client_test.go ( #5154 )
...
Signed-off-by: yudong.cai <yudong.cai@zilliz.com>
2021-05-10 02:32:10 +00: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
yukun
964e7e0a28
Add unittest for mqclient
...
Signed-off-by: yukun <kun.yu@zilliz.com>
2021-04-08 20:05:33 +08:00