clusterStatus
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