| def clusterStatus: ClusterStatus = { | |
| val isLeader = leaderLatch.hasLeadership | |
| val participants = leaderLatch.getParticipants.asScala | |
| val leader = participants.find(_.isLeader).map(_.getId).getOrElse("<none>") | |
| ClusterStatus(nodeId, isLeader, leader, participants.map(_.getId)) | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment