Package org.elasticsearch.cluster.coordination

Class PublicationTransportHandler

java.lang.Object

org.elasticsearch.cluster.coordination.PublicationTransportHandler

public class PublicationTransportHandler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	PublicationTransportHandler.PublicationContext	Publishing a cluster state typically involves sending the same cluster state (or diff) to every node, so the work of diffing, serializing, and compressing the state can be done once and the results shared across publish requests.

Field Summary

Fields

Modifier and Type	Field	Description
static String	COMMIT_STATE_ACTION_NAME
static String	PUBLISH_STATE_ACTION_NAME

Constructor Summary

Constructors

Constructor	Description
PublicationTransportHandler(TransportService transportService, NamedWriteableRegistry namedWriteableRegistry, Function<PublishRequest,PublishWithJoinResponse> handlePublishRequest, BiConsumer<ApplyCommitRequest,ActionListener<Void>> handleApplyCommit)

Method Summary

Modifier and Type	Method	Description
PublicationTransportHandler.PublicationContext	newPublicationContext(ClusterChangedEvent clusterChangedEvent)
PublishClusterStateStats	stats()

Methods inherited from class java.lang.Object

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

Field Details

PUBLISH_STATE_ACTION_NAME

public static final String PUBLISH_STATE_ACTION_NAME

See Also:

Constant Field Values

COMMIT_STATE_ACTION_NAME

public static final String COMMIT_STATE_ACTION_NAME

See Also:

Constant Field Values

Constructor Details

PublicationTransportHandler

public PublicationTransportHandler(TransportService transportService,
 NamedWriteableRegistry namedWriteableRegistry,
 Function<PublishRequest,PublishWithJoinResponse> handlePublishRequest,
 BiConsumer<ApplyCommitRequest,ActionListener<Void>> handleApplyCommit)

Method Details

stats

public PublishClusterStateStats stats()

newPublicationContext

public PublicationTransportHandler.PublicationContext newPublicationContext(ClusterChangedEvent clusterChangedEvent)