Module org.elasticsearch.server

Package org.elasticsearch.cluster.service

Class TransportVersionsFixupListener

java.lang.Object

org.elasticsearch.cluster.service.TransportVersionsFixupListener

All Implemented Interfaces:

ClusterStateListener

public class TransportVersionsFixupListener
extends Object
implements ClusterStateListener

This fixes up the transport version from pre-8.8.0 cluster state that was inferred as the minimum possible, due to the master node not understanding cluster state with transport versions added in 8.8.0. Any nodes with the inferred placeholder cluster state is then refreshed with their actual transport version

Constructor Summary

Constructors

Constructor	Description
TransportVersionsFixupListener(ClusterService service, ClusterAdminClient client, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	clusterChanged(ClusterChangedEvent event)	Called when cluster state changes.

Methods inherited from class java.lang.Object

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

Constructor Details

TransportVersionsFixupListener

public TransportVersionsFixupListener(ClusterService service,
 ClusterAdminClient client,
 Scheduler scheduler)

Method Details

clusterChanged

public void clusterChanged(ClusterChangedEvent event)

Description copied from interface: ClusterStateListener

Called when cluster state changes.

Cluster states are applied one-by-one which means they can be a performance bottleneck. Implementations of this method should therefore be fast, so please consider forking work into the background rather than doing everything inline.

Specified by:

clusterChanged in interface ClusterStateListener