Class Publication
- java.lang.Object
-
- org.elasticsearch.cluster.coordination.Publication
-
public abstract class Publication extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.logging.log4j.Logger
logger
-
Constructor Summary
Constructors Constructor Description Publication(PublishRequest publishRequest, ClusterStatePublisher.AckListener ackListener, java.util.function.LongSupplier currentTimeSupplier)
-
Method Summary
Modifier and Type Method Description void
cancel(java.lang.String reason)
java.util.List<DiscoveryNode>
completedNodes()
protected abstract java.util.Optional<ApplyCommitRequest>
handlePublishResponse(DiscoveryNode sourceNode, PublishResponse publishResponse)
boolean
isCommitted()
protected abstract boolean
isPublishQuorum(CoordinationState.VoteCollection votes)
protected abstract void
onCompletion(boolean committed)
void
onFaultyNode(DiscoveryNode faultyNode)
protected abstract void
onJoin(Join join)
protected abstract void
onMissingJoin(DiscoveryNode discoveryNode)
protected abstract void
sendApplyCommit(DiscoveryNode destination, ApplyCommitRequest applyCommit, ActionListener<TransportResponse.Empty> responseActionListener)
protected abstract void
sendPublishRequest(DiscoveryNode destination, PublishRequest publishRequest, ActionListener<PublishWithJoinResponse> responseActionListener)
void
start(java.util.Set<DiscoveryNode> faultyNodes)
java.lang.String
toString()
-
-
-
Constructor Detail
-
Publication
public Publication(PublishRequest publishRequest, ClusterStatePublisher.AckListener ackListener, java.util.function.LongSupplier currentTimeSupplier)
-
-
Method Detail
-
start
public void start(java.util.Set<DiscoveryNode> faultyNodes)
-
cancel
public void cancel(java.lang.String reason)
-
onFaultyNode
public void onFaultyNode(DiscoveryNode faultyNode)
-
completedNodes
public java.util.List<DiscoveryNode> completedNodes()
-
isCommitted
public boolean isCommitted()
-
onCompletion
protected abstract void onCompletion(boolean committed)
-
isPublishQuorum
protected abstract boolean isPublishQuorum(CoordinationState.VoteCollection votes)
-
handlePublishResponse
protected abstract java.util.Optional<ApplyCommitRequest> handlePublishResponse(DiscoveryNode sourceNode, PublishResponse publishResponse)
-
onJoin
protected abstract void onJoin(Join join)
-
onMissingJoin
protected abstract void onMissingJoin(DiscoveryNode discoveryNode)
-
sendPublishRequest
protected abstract void sendPublishRequest(DiscoveryNode destination, PublishRequest publishRequest, ActionListener<PublishWithJoinResponse> responseActionListener)
-
sendApplyCommit
protected abstract void sendApplyCommit(DiscoveryNode destination, ApplyCommitRequest applyCommit, ActionListener<TransportResponse.Empty> responseActionListener)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-