Package | Description |
---|---|
com.hp.util.dcord |
Distributed Coordination Service API.
|
com.hp.util.dcord.election |
Authority that determines whether the local node is eligible for election.
|
com.hp.util.dcord.hazelcast |
Distributed Coordination Service implementation using Hazelcast as the underlying technoligy.
|
com.hp.util.dcord.peer |
Peer Monitor Service.
|
Modifier and Type | Method and Description |
---|---|
Node |
ClusterService.getLocalNode()
Gets the local node.
|
Node |
MessageEvent.getSource()
Gets the source.
|
Node |
EntryEvent.getSource()
Gets the source.
|
Modifier and Type | Method and Description |
---|---|
Set<Node> |
ClusterService.getActiveNodes()
Returns the active nodes that currently form the cluster.
|
Set<Node> |
ClusterService.getConfiguredNodes()
Returns the set of nodes that should form a complete cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterListener.onJoin(Node node)
Method to notify a node has joined the cluster.
|
void |
ClusterListener.onLeave(Node node)
Method to notify a node has left the cluster.
|
Constructor and Description |
---|
EntryEvent(K key,
V value,
V oldValue,
Namespace namespace,
Node source)
Creates an entry event.
|
MessageEvent(M message,
Node source)
Creates a message event.
|
Modifier and Type | Method and Description |
---|---|
Node |
ElectionStrategy.elect(Set<Node> candidates,
Node suggested,
Set<Node> active,
Set<Node> configured)
Elects a leader from the set of candidates.
|
Node |
ElectionService.getLeader()
Returns the leaderMap if one has been elected,
null if the
cluster has no leaderMap. |
Modifier and Type | Method and Description |
---|---|
Node |
ElectionStrategy.elect(Set<Node> candidates,
Node suggested,
Set<Node> active,
Set<Node> configured)
Elects a leader from the set of candidates.
|
void |
ElectionListener.onElection(Node newleader,
Node oldLeader)
Callback method to notify the result of an election.
|
void |
ElectionService.onJoin(Node node) |
void |
ElectionService.onLeave(Node node) |
Modifier and Type | Method and Description |
---|---|
Node |
ElectionStrategy.elect(Set<Node> candidates,
Node suggested,
Set<Node> active,
Set<Node> configured)
Elects a leader from the set of candidates.
|
Node |
ElectionStrategy.elect(Set<Node> candidates,
Node suggested,
Set<Node> active,
Set<Node> configured)
Elects a leader from the set of candidates.
|
Node |
ElectionStrategy.elect(Set<Node> candidates,
Node suggested,
Set<Node> active,
Set<Node> configured)
Elects a leader from the set of candidates.
|
Modifier and Type | Method and Description |
---|---|
Set<Node> |
State.getActiveNodes()
Gets the cluster's active nodes.
|
Modifier and Type | Method and Description |
---|---|
Collection<Pair<Node,P>> |
PubSubPeerMonitor.getKnownPeers() |
Collection<Pair<Node,P>> |
PeerMonitor.getKnownPeers()
Gets known peers (including the local peer if its initial state has
been reported via
PeerMonitor.updateLocalPeer(Object) ) which are the peers
for which the state is considered up to date. |
Collection<Pair<Node,P>> |
PubSubPeerMonitor.getUnknownPeers() |
Collection<Pair<Node,P>> |
PeerMonitor.getUnknownPeers()
Gets unknown peers (including the local peer if its initial state has
not been reported via
PeerMonitor.updateLocalPeer(Object) ) which are the
peers for which the state is considered unknown or out of date: These
are peers that have never joined the cluster, peers that have not
reported status after they left, or peers that previously reported
status but the node they belong to are not part of
ClusterService.getActiveNodes() . |
Modifier and Type | Method and Description |
---|---|
void |
PeerListener.onBecomingUnknown(Node node,
P lastKnownStatus)
Notifies when a peer becomes unknown.
|
void |
PeerListener.onUpdate(Node node,
P currentStatus)
Notifies received remote peers' status updates.
|
Copyright © 2015. All Rights Reserved.