-
Notifications
You must be signed in to change notification settings - Fork 33
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Rearchitect pulse mechanism #356
base: master
Are you sure you want to change the base?
Conversation
@@ -59,13 +59,27 @@ | |||
import static org.junit.Assert.assertEquals; | |||
|
|||
@SuppressWarnings("Duplicates") | |||
|
|||
class ClientQueryTest2 { |
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.
TODO: remove
@@ -45,8 +45,8 @@ def vaticle_dependencies(): | |||
def vaticle_typedb_protocol(): | |||
git_repository( | |||
name = "vaticle_typedb_protocol", | |||
remote = "https://github.com/vaticle/typedb-protocol", | |||
commit = "3300d136a35f35bed58137bb79a6e3774dd170b9", # sync-marker: do not remove this comment, this is used for sync-dependencies by @vaticle_typedb_protocol | |||
remote = "https://github.com/lolski/typedb-protocol", |
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.
TODO: update
connection/TypeDBClientImpl.java
Outdated
boolean alive; | ||
try { | ||
alive = stub().clientPulse(pulseReq(ID())).getAlive(); | ||
System.out.println("client pulse - alive: " + alive); |
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.
TODO: remove log statement
2b71a2b
to
5df4e8a
Compare
9de6052
to
5932aad
Compare
What is the goal of this PR?
We've moved the pulse mechanism from session to client. Architecturally it makes more sense - the pulse is a mechanism to detect liveness and it's the client that may crash or gets cut off from the network, not any particular individual session instance owned by the client.
What are the changes implemented in this PR?
create
methods with regular constructors