Package | Description |
---|---|
org.elasticsearch.river.cluster | |
org.elasticsearch.river.routing |
Modifier and Type | Method and Description |
---|---|
RiverClusterState |
RiverClusterState.Builder.build() |
RiverClusterState |
RiverClusterStateUpdateTask.execute(RiverClusterState currentState) |
RiverClusterState |
RiverClusterChangedEvent.previousState() |
static RiverClusterState |
RiverClusterState.Builder.readFrom(StreamInput in) |
RiverClusterState |
RiverClusterChangedEvent.state() |
Modifier and Type | Method and Description |
---|---|
RiverClusterState |
RiverClusterStateUpdateTask.execute(RiverClusterState currentState) |
void |
PublishRiverClusterStateAction.NewClusterStateListener.onNewClusterState(RiverClusterState clusterState) |
void |
PublishRiverClusterStateAction.publish(RiverClusterState clusterState) |
RiverClusterState.Builder |
RiverClusterState.Builder.state(RiverClusterState state) |
static void |
RiverClusterState.Builder.writeTo(RiverClusterState clusterState,
StreamOutput out) |
Constructor and Description |
---|
RiverClusterChangedEvent(String source,
RiverClusterState state,
RiverClusterState previousState) |
RiverClusterState(long version,
RiverClusterState state) |
Modifier and Type | Method and Description |
---|---|
protected RiverClusterState |
RiversRouter.updateRiverClusterState(String source,
RiverClusterState currentState,
ClusterState newClusterState,
CountDown countDown) |
Modifier and Type | Method and Description |
---|---|
protected RiverClusterState |
RiversRouter.updateRiverClusterState(String source,
RiverClusterState currentState,
ClusterState newClusterState,
CountDown countDown) |
Copyright © 2009–2015. All rights reserved.