Package org.elasticsearch.discovery.zen

Class PublishClusterStateAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.discovery.zen.PublishClusterStateAction

public class PublishClusterStateAction
extends AbstractComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	PublishClusterStateAction.CommitClusterStateRequest
static interface	PublishClusterStateAction.IncomingClusterStateListener

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COMMIT_ACTION_NAME
static java.lang.String	SEND_ACTION_NAME

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
PublishClusterStateAction(Settings settings, TransportService transportService, NamedWriteableRegistry namedWriteableRegistry, PublishClusterStateAction.IncomingClusterStateListener incomingClusterStateListener, DiscoverySettings discoverySettings)

Method Summary

Modifier and Type	Method	Description
protected void	handleCommitRequest(PublishClusterStateAction.CommitClusterStateRequest request, TransportChannel channel)
protected void	handleIncomingClusterStateRequest(BytesTransportRequest request, TransportChannel channel)
void	publish(ClusterChangedEvent clusterChangedEvent, int minMasterNodes, Discovery.AckListener ackListener)	publishes a cluster change event to other nodes.
static BytesReference	serializeDiffClusterState(Diff diff, Version nodeVersion)
static BytesReference	serializeFullClusterState(ClusterState clusterState, Version nodeVersion)
PublishClusterStateStats	stats()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SEND_ACTION_NAME

public static final java.lang.String SEND_ACTION_NAME

See Also:

Constant Field Values

COMMIT_ACTION_NAME

public static final java.lang.String COMMIT_ACTION_NAME

See Also:

Constant Field Values

Constructor Detail

PublishClusterStateAction

public PublishClusterStateAction(Settings settings,
                                 TransportService transportService,
                                 NamedWriteableRegistry namedWriteableRegistry,
                                 PublishClusterStateAction.IncomingClusterStateListener incomingClusterStateListener,
                                 DiscoverySettings discoverySettings)

Method Detail

publish

public void publish(ClusterChangedEvent clusterChangedEvent,
                    int minMasterNodes,
                    Discovery.AckListener ackListener)
             throws Discovery.FailedToCommitClusterStateException

publishes a cluster change event to other nodes. if at least minMasterNodes acknowledge the change it is committed and will be processed by the master and the other nodes.

The method is guaranteed to throw a Discovery.FailedToCommitClusterStateException if the change is not committed and should be rejected. Any other exception signals the something wrong happened but the change is committed.

Throws:

Discovery.FailedToCommitClusterStateException

serializeFullClusterState

public static BytesReference serializeFullClusterState(ClusterState clusterState,
                                                       Version nodeVersion)
                                                throws java.io.IOException

Throws:

java.io.IOException

serializeDiffClusterState

public static BytesReference serializeDiffClusterState(Diff diff,
                                                       Version nodeVersion)
                                                throws java.io.IOException

Throws:

java.io.IOException

handleIncomingClusterStateRequest

protected void handleIncomingClusterStateRequest(BytesTransportRequest request,
                                                 TransportChannel channel)
                                          throws java.io.IOException

Throws:

java.io.IOException

handleCommitRequest

protected void handleCommitRequest(PublishClusterStateAction.CommitClusterStateRequest request,
                                   TransportChannel channel)

stats

public PublishClusterStateStats stats()