-
Notifications
You must be signed in to change notification settings - Fork 1
004 add client server #30
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
Conversation
| ) | ||
| // Simplified demo - just show that KVStateMachine compiles | ||
| // Full integration would require session management setup | ||
| ZIO.succeed(println("KVStore with SessionStateMachine - compilation successful")).exitCode |
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.
very simple 😆
|
|
||
| // Helpers | ||
| private def putValue(key: KVKey, value: String): SW[Unit] = | ||
| StateWriter.update[HMap[Schema], HMap[Schema]](s => s.updated["kv"](key, value)) |
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.
can we maybe add helper methods to SessionStateMachine like get and update? maybe to simplify StateWriter.update[HMap[Schema], HMap[Schema]] ?
b51518a to
f95d8fc
Compare
95766c9 to
505c3a4
Compare
505c3a4 to
450985a
Compare
| ZIO | ||
| .logDebug(s"memberId=${this.memberId} read pending command index=$index") | ||
| .as(l.withReadPendingCommand(r.promise, index)) | ||
| case None if peers.size == 0 => |
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.
@keisar reading state one a singe node cluster didn't work... I added this
No description provided.