Package 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:

Writeable, StatusToXContentObject, org.elasticsearch.core.RefCounted, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject

public class ClusterHealthResponse
extends ActionResponse
implements StatusToXContentObject

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.ActionResponse

ActionResponse.Empty

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

org.elasticsearch.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.xcontent.ToXContent.MapParams, org.elasticsearch.xcontent.ToXContent.Params

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields inherited from interface org.elasticsearch.xcontent.ToXContent

EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
ClusterHealthResponse()
ClusterHealthResponse(String clusterName, String[] concreteIndices, ClusterState clusterState)	needed for plugins BWC
ClusterHealthResponse(String clusterName, String[] concreteIndices, ClusterState clusterState, int numberOfPendingTasks, int numberOfInFlightFetch, int delayedUnassignedShards, org.elasticsearch.core.TimeValue taskMaxWaitingTime)
ClusterHealthResponse(StreamInput in)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static ClusterHealthResponse	fromXContent(org.elasticsearch.xcontent.XContentParser parser)
int	getActivePrimaryShards()
int	getActiveShards()
double	getActiveShardsPercent()	The percentage of active shards, should be 100% in a green system
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).
Map<String,ClusterIndexHealth>	getIndices()
int	getInitializingShards()
int	getNumberOfDataNodes()
int	getNumberOfInFlightFetch()
int	getNumberOfNodes()
int	getNumberOfPendingTasks()
int	getRelocatingShards()
ClusterHealthStatus	getStatus()
org.elasticsearch.core.TimeValue	getTaskMaxWaitingTime()
int	getUnassignedShards()
int	hashCode()
boolean	isTimedOut()	true if the waitForXXX has timeout out and did not match.
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
String	toString()
org.elasticsearch.xcontent.XContentBuilder	toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params)
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class org.elasticsearch.transport.TransportMessage

decRef, hasReferences, incRef, remoteAddress, remoteAddress, tryIncRef

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.xcontent.ToXContentObject

isFragment

Constructor Details

ClusterHealthResponse

public ClusterHealthResponse()

ClusterHealthResponse

public ClusterHealthResponse(StreamInput in)
                      throws IOException

Throws:

IOException

ClusterHealthResponse

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

needed for plugins BWC

ClusterHealthResponse

public ClusterHealthResponse(String clusterName,
 String[] concreteIndices,
 ClusterState clusterState,
 int numberOfPendingTasks,
 int numberOfInFlightFetch,
 int delayedUnassignedShards,
 org.elasticsearch.core.TimeValue taskMaxWaitingTime)

Method Details

getClusterName

public 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 Map<String,ClusterIndexHealth> getIndices()

getTaskMaxWaitingTime

public org.elasticsearch.core.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 IOException

Throws:

IOException

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class 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 org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder,
 org.elasticsearch.xcontent.ToXContent.Params params)
                                                      throws IOException

Specified by:

toXContent in interface org.elasticsearch.xcontent.ToXContent

Throws:

IOException

fromXContent

public static ClusterHealthResponse fromXContent(org.elasticsearch.xcontent.XContentParser parser)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object