public class ClusterHeartbeatManager extends Object
Modifier and Type | Method and Description |
---|---|
long |
getHeartbeatIntervalMillis() |
PingFailureDetector |
getIcmpFailureDetector() |
long |
getLastHeartbeatTime(Member member) |
void |
handleHeartbeat(MembersViewMetadata senderMembersViewMetadata,
String receiverUuid,
long timestamp) |
void |
handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata,
MembersViewMetadata senderMVMetadata) |
void |
onHeartbeat(MemberImpl member,
long timestamp)
Accepts the heartbeat message from
member created at timestamp . |
public long getHeartbeatIntervalMillis()
public long getLastHeartbeatTime(Member member)
public void handleHeartbeat(MembersViewMetadata senderMembersViewMetadata, String receiverUuid, long timestamp)
public void handleHeartbeatComplaint(MembersViewMetadata receiverMVMetadata, MembersViewMetadata senderMVMetadata)
public void onHeartbeat(MemberImpl member, long timestamp)
member
created at timestamp
. The timestamp must be
related to the cluster clock, not the local clock. The heartbeat is ignored if the duration between
timestamp
and the current cluster time is more than GroupProperty.MAX_NO_HEARTBEAT_SECONDS
/2.
If the sending node is the master, this node will also calculate and set the cluster clock diff.member
- the member sending the heartbeattimestamp
- the timestamp when the heartbeat was createdpublic PingFailureDetector getIcmpFailureDetector()
icmpFailureDetector
if configured, otherwise null
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.