-
bf539f6...
by
lizhanhui
-
Add test for Ord of AppendRecordRequest
Signed-off-by: Li Zhanhui <email address hidden>
-
57c9f1a...
by
lizhanhui
-
feat(data-node): Implement append window for data node (#235)
* Add unit tests for StreamManager#Range
Signed-off-by: Li Zhanhui <email address hidden>
* Add test cases for stream
Signed-off-by: Li Zhanhui <email address hidden>
* to #200 Implement Window so that append requests are dispatched to store in order
Signed-off-by: Li Zhanhui <email address hidden>
* Fix unit tests
Signed-off-by: Li Zhanhui <email address hidden>
---------
Signed-off-by: Li Zhanhui <email address hidden>
-
374f592...
by
lizhanhui
-
feat(SDK): Define Rust API for Java SDK (#236)
Define Rust API for Java SDK
Signed-off-by: Li Zhanhui <email address hidden>
-
2576221...
by
Robin Han <email address hidden>
-
feat(replication range): range append (#234)
* ~
Signed-off-by: Robin Han <email address hidden>
* feat(replication range): add append record batch encode
Signed-off-by: Robin Han <email address hidden>
* fix(PR): check append result status
Signed-off-by: Robin Han <email address hidden>
---------
Signed-off-by: Robin Han <email address hidden>
-
8ff6c46...
by
Robin Han <email address hidden>
-
feat(replication range): range seal (#232)
Signed-off-by: Robin Han <email address hidden>
-
5cc3340...
by
Robin Han <email address hidden>
-
feat(replication range): add new range (#231)
* feat(replication range): add new range
Signed-off-by: Robin Han <email address hidden>
* fix(PR): parallel create range replica
Signed-off-by: Robin Han <email address hidden>
---------
Signed-off-by: Robin Han <email address hidden>
-
4080fec...
by
Yu Ning <email address hidden>
-
fix(pm): Get all placement manager nodes info (#233)
* refactor(pm): Get all members by `client.MemberList`
Signed-off-by: Ning Yu <email address hidden>
* feat(pm/member): Save sbp address in etcd
Signed-off-by: Ning Yu <email address hidden>
* test(pm/member): Test `ClusterInfo`
Signed-off-by: Ning Yu <email address hidden>
---------
Signed-off-by: Ning Yu <email address hidden>
-
f88ec95...
by
lizhanhui
-
feat(data-node): Load max committed offset by range on bootstrap (#230)
fix #229 Load max committed offset by range on bootstrap
Signed-off-by: Li Zhanhui <email address hidden>
-
3d80a13...
by
Robin Han <email address hidden>
-
feat(replication stream): add stream fetch support (#228)
* feat(replication stream): add stream fetch support
Signed-off-by: Robin Han <email address hidden>
* fix(PR)
Signed-off-by: Robin Han <email address hidden>
---------
Signed-off-by: Robin Han <email address hidden>
-
b2723ae...
by
Robin Han <email address hidden>
-
fix(replication range): fix range seal (#227)
* fix(replication range): fix range seal
Signed-off-by: Robin Han <email address hidden>
* fix(PR)
Signed-off-by: Robin Han <email address hidden>
* fix(PR)
Signed-off-by: Robin Han <email address hidden>
---------
Signed-off-by: Robin Han <email address hidden>
