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()
-
Field Details
-
logger
protected final org.apache.logging.log4j.Logger logger
-
-
Constructor Details
-
Publication
public Publication(PublishRequest publishRequest, ClusterStatePublisher.AckListener ackListener, java.util.function.LongSupplier currentTimeSupplier)
-
-
Method Details
-
start
-
cancel
public void cancel(java.lang.String reason) -
onFaultyNode
-
completedNodes
-
isCommitted
public boolean isCommitted() -
onCompletion
protected abstract void onCompletion(boolean committed) -
isPublishQuorum
-
handlePublishResponse
protected abstract java.util.Optional<ApplyCommitRequest> handlePublishResponse(DiscoveryNode sourceNode, PublishResponse publishResponse) -
onJoin
-
onMissingJoin
-
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
-