-
Notifications
You must be signed in to change notification settings - Fork 26
Conversation
} | ||
/// TODO need refactor | ||
// #[inline] | ||
// async fn join(&self, vec_cmd: Vec<CommandData>) -> Result<Vec<Option<Vec<u8>>>> {} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
mark
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why not implement this function
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The return type of this function is not reasonable. For batch operations, we should tell client which part succeed and which part failed.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
sure
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The return type of this function is not reasonable. For batch operations, we should tell client which part succeed and which part failed.
refer to the use of futures::try_join method, either all succeed at once, or all fail.
} | ||
/// TODO need refactor | ||
// #[inline] | ||
// async fn join(&self, vec_cmd: Vec<CommandData>) -> Result<Vec<Option<Vec<u8>>>> {} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why not implement this function
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Server refactoring is perfect, But the join()
method is somewhat controversial, and I hope to add a simple example in Examples.
} | ||
/// TODO need refactor | ||
// #[inline] | ||
// async fn join(&self, vec_cmd: Vec<CommandData>) -> Result<Vec<Option<Vec<u8>>>> {} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The return type of this function is not reasonable. For batch operations, we should tell client which part succeed and which part failed.
refer to the use of futures::try_join method, either all succeed at once, or all fail.
|
||
package kipdb; | ||
|
||
service KipdbRpc { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cool, learned
Can you add some RPC related descriptions to README.md please? |
I think the |
like users are required to install |
Join remove will be put in follow up pr. |
What problem does this PR solve?
Refactor server
Issue link: #47
What is changed and how it works?
Code changes
Check List
Tests
Side effects
Note for reviewer