jaime
|
9630974fbb
enhance: move rocksmq from internal to pkg module (#33881)
|
3 月之前 |
SimFG
|
cb99e3db34
enhance: add the includeCurrentMsg param for the Seek method (#33326)
|
4 月之前 |
SimFG
|
26f06dd732
Format the code (#27275)
|
1 年之前 |
XuanYang-cn
|
7f1ae35e72
Add timeout in dispatcher, AsConsumer and Seek (#26686)
|
1 年之前 |
Enwei Jiao
|
fb0705df1b
Decouple basetable and componentparam (#26725)
|
1 年之前 |
SimFG
|
0c3f92d7d7
Improve the panic code about the rootcoord/session/rocksmq (#24859) (#25024)
|
1 年之前 |
smellthemoon
|
f1adb1c06d
can only use the topic in the list when preCreatedTopicEnabled (#23913)
|
1 年之前 |
jaime
|
c9d0c157ec
Move some modules from internal to public package (#22572)
|
1 年之前 |
smellthemoon
|
ce91f61e5a
Pre-create topics (#21907)
|
1 年之前 |
Enwei Jiao
|
697dedac7e
Use cockroachdb/errors to replace other error pkg (#22390)
|
1 年之前 |
jaime
|
039e9ce4bb
Refine msgstream interface (#20832)
|
1 年之前 |
Xiaofan
|
1f170ce1ba
Refine kafka consumer (#19846)
|
2 年之前 |
Jiquan Long
|
1817627316
Fix create collection failed to assign channels (#19551)
|
2 年之前 |
congqixia
|
b62cb82ebe
Simplify Dml-DeltaChannel mapping logic (#18702)
|
2 年之前 |
congqixia
|
318cdbebe9
Add heap for dmlChannels to get next channel (#18451)
|
2 年之前 |
godchen
|
bb7a0766fe
Add dependency factory (#16204)
|
2 年之前 |
xiyichan
|
ca129d4308
Support configurable msgstream (#16131)
|
2 年之前 |
jaime
|
97b1ed7bca
Remove reader API from Mqstream and replace it with consumer API (#15971)
|
2 年之前 |
jaime
|
29975a7a26
Remove Consume() API from mqstream interface (#15886)
|
2 年之前 |
jaime
|
7a3a721380
Reconstruct mqstream module (#15784)
|
2 年之前 |
Cai Yudong
|
7efb02a4c5
Use PulsarConfig in GlobalParams for all components (#15046)
|
2 年之前 |
Xiaofan
|
69087ff8dd
Support embedded etcd (#14333)
|
2 年之前 |
Cai Yudong
|
891c202b73
Use GlobalParamTable for all components (#13885)
|
2 年之前 |
XuanYang-cn
|
c544bb21ac
[skip ci]Update license for rc dml channels (#13497)
|
2 年之前 |
XuanYang-cn
|
a9a332dbcf
Fix empty segment compact and load (#12710)
|
2 年之前 |
Cai Yudong
|
858e95f377
Move dmlChannel and deltaChannel into timeticksync (#12254)
|
2 年之前 |
Cai Yudong
|
d4c297b1a8
Enhance dml channel operations (#12143)
|
2 年之前 |
Cai Yudong
|
d10c6abc9e
Apply for msgstream from pool when creating collection (#7738)
|
3 年之前 |
Cai Yudong
|
4e23ed9a18
Revert apply physical channels from pool (d5f7e358 and 3b960969) (#7687)
|
3 年之前 |
Cai Yudong
|
d5f7e358aa
Let dml tolerant physical channels generated by old version (#7644)
|
3 年之前 |