| 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–2016. All rights reserved.