org.elasticsearch.action.admin.cluster.health

Class ClusterHealthResponse

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportResponse

org.elasticsearch.action.ActionResponse

org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse

All Implemented Interfaces:

Streamable, StatusToXContentObject, ToXContent, ToXContentObject

public class ClusterHealthResponse
extends ActionResponse
implements StatusToXContentObject

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportResponse

TransportResponse.Empty

Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent

ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params

Field Summary

Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent

EMPTY_PARAMS

Constructor Summary

Constructors

Constructor and Description
ClusterHealthResponse(java.lang.String clusterName, java.lang.String[] concreteIndices, ClusterState clusterState) needed for plugins BWC
ClusterHealthResponse(java.lang.String clusterName, java.lang.String[] concreteIndices, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch, int delayedUnassignedShards, TimeValue taskMaxWaitingTime)

Method Summary

Modifier and Type	Method and Description
int	getActivePrimaryShards()
int	getActiveShards()
double	getActiveShardsPercent() The percentage of active shards, should be 100% in a green system
java.lang.String	getClusterName()
int	getDelayedUnassignedShards() The number of unassigned shards that are currently being delayed (for example, due to node leaving the cluster and waiting for a timeout for the node to come back in order to allocate the shards back to it).
java.util.Map<java.lang.String,ClusterIndexHealth>	getIndices()
int	getInitializingShards()
int	getNumberOfDataNodes()
int	getNumberOfInFlightFetch()
int	getNumberOfNodes()
int	getNumberOfPendingTasks()
int	getRelocatingShards()
ClusterHealthStatus	getStatus()
TimeValue	getTaskMaxWaitingTime()
int	getUnassignedShards()
boolean	isTimedOut() true if the waitForXXX has timeout out and did not match.
void	readFrom(StreamInput in) Set this object's fields from a StreamInput.
static ClusterHealthResponse	readResponseFrom(StreamInput in)
void	setStatus(ClusterHealthStatus status) Allows to explicitly override the derived cluster health status.
void	setTimedOut(boolean timedOut)
RestStatus	status() Returns the REST status to make sure it is returned correctly
java.lang.String	toString()
XContentBuilder	toXContent(XContentBuilder builder, ToXContent.Params params)
void	writeTo(StreamOutput out) Write this object's fields to a StreamOutput.

Methods inherited from class org.elasticsearch.transport.TransportMessage

remoteAddress, remoteAddress

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.xcontent.ToXContentObject

isFragment

Constructor Detail

ClusterHealthResponse

public ClusterHealthResponse(java.lang.String clusterName,
                             java.lang.String[] concreteIndices,
                             ClusterState clusterState)

needed for plugins BWC

ClusterHealthResponse

public ClusterHealthResponse(java.lang.String clusterName,
                             java.lang.String[] concreteIndices,
                             ClusterState clusterState,
                             int numberOfPendingTasks,
                             int numberOfInFlightFetch,
                             int delayedUnassignedShards,
                             TimeValue taskMaxWaitingTime)

Method Detail

getClusterName

public java.lang.String getClusterName()

getActiveShards

public int getActiveShards()

getRelocatingShards

public int getRelocatingShards()

getActivePrimaryShards

public int getActivePrimaryShards()

getInitializingShards

public int getInitializingShards()

getUnassignedShards

public int getUnassignedShards()

getNumberOfNodes

public int getNumberOfNodes()

getNumberOfDataNodes

public int getNumberOfDataNodes()

getNumberOfPendingTasks

public int getNumberOfPendingTasks()

getNumberOfInFlightFetch

public int getNumberOfInFlightFetch()

getDelayedUnassignedShards

public int getDelayedUnassignedShards()

The number of unassigned shards that are currently being delayed (for example, due to node leaving the cluster and waiting for a timeout for the node to come back in order to allocate the shards back to it).

isTimedOut

public boolean isTimedOut()

true if the waitForXXX has timeout out and did not match.

setTimedOut

public void setTimedOut(boolean timedOut)

getStatus

public ClusterHealthStatus getStatus()

setStatus

public void setStatus(ClusterHealthStatus status)

Allows to explicitly override the derived cluster health status.

Parameters:

status - The override status. Must not be null.

getIndices

public java.util.Map<java.lang.String,ClusterIndexHealth> getIndices()

getTaskMaxWaitingTime

public TimeValue getTaskMaxWaitingTime()

Returns:

The maximum wait time of all tasks in the queue

getActiveShardsPercent

public double getActiveShardsPercent()

The percentage of active shards, should be 100% in a green system

readResponseFrom

public static ClusterHealthResponse readResponseFrom(StreamInput in)
                                              throws java.io.IOException

Throws:

java.io.IOException

readFrom

public void readFrom(StreamInput in)
              throws java.io.IOException

Description copied from interface: Streamable

Set this object's fields from a StreamInput.

Specified by:

readFrom in interface Streamable

Overrides:

readFrom in class ActionResponse

Throws:

java.io.IOException

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Streamable

Write this object's fields to a StreamOutput.

Specified by:

writeTo in interface Streamable

Overrides:

writeTo in class ActionResponse

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

status

public RestStatus status()

Description copied from interface: StatusToXContentObject

Returns the REST status to make sure it is returned correctly

Specified by:

status in interface StatusToXContentObject

toXContent

public XContentBuilder toXContent(XContentBuilder builder,
                                  ToXContent.Params params)
                           throws java.io.IOException

Specified by:

toXContent in interface ToXContent

Throws:

java.io.IOException