Interface ClusterApplier
- All Known Implementing Classes:
ClusterApplierService
public interface ClusterApplier
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic interface
Listener for results of cluster state application -
Method Summary
Modifier and TypeMethodDescriptionvoid
onNewClusterState(String source, Supplier<ClusterState> clusterStateSupplier, ClusterApplier.ClusterApplyListener listener)
Method to invoke when a new cluster state is available to be appliedvoid
setInitialState(ClusterState initialState)
Sets the initial state for this applier.
-
Method Details
-
setInitialState
Sets the initial state for this applier. Should only be called once.- Parameters:
initialState
- the initial state to set
-
onNewClusterState
void onNewClusterState(String source, Supplier<ClusterState> clusterStateSupplier, ClusterApplier.ClusterApplyListener listener)Method to invoke when a new cluster state is available to be applied- Parameters:
source
- information where the cluster state came fromclusterStateSupplier
- the cluster state supplier which provides the latest cluster state to applylistener
- callback that is invoked after cluster state is applied
-