Implemented cluster State action.

Author: Cihat Keser

src/main/java/io/searchbox/cluster/State.java

@@ -1,9 +1,77 @@
 package io.searchbox.cluster;
 
+import io.searchbox.AbstractAction;
+
 /**
  * @author Dogukan Sonmez
+ * @author cihat keser
  */
+public class State extends AbstractAction {
+
+    public State(Builder builder) {
+        super(builder);
+        setURI(buildURI());
+    }
+
+    @Override
+    protected String buildURI() {
+        StringBuilder sb = new StringBuilder(super.buildURI());
+        sb.append("/_cluster/state");
+        return sb.toString();
+    }
+
+    @Override
+    public String getRestMethodName() {
+        return "GET";
+    }
+
+    public static class Builder extends AbstractAction.Builder<State, Builder> {
+
+        /**
+         * Set to true to filter out the routing_table part of the response.
+         */
+        public Builder filterRoutingTable(boolean value) {
+            return setParameter("filter_routing_table", value);
+        }
+
+        /**
+         * Set to true to filter out the metadata part of the response.
+         */
+        public Builder filterMetadata(boolean value) {
+            return setParameter("filter_metadata", value);
+        }
+
+        /**
+         * Set to true to filter out the blocks part of the response.
+         */
+        public Builder filterBlocks(boolean value) {
+            return setParameter("filter_blocks", value);
+        }
+
+        /**
+         * When not filtering metadata, a comma separated list of indices to include in the response.
+         */
+        public Builder filterIndices(String value) {
+            return setParameter("filter_indices", value);
+        }
+
+        /**
+         * Set to true to filter out the nodes part of the response.
+         */
+        public Builder filterNodes(boolean value) {
+            return setParameter("filter_nodes", value);
+        }
 
+        /**
+         * For debugging purposes, you can retrieve the cluster state local to a particular node.
+         */
+        public Builder local(boolean value) {
+            return setParameter("local", value);
+        }
 
-public class State {
+        @Override
+        public State build() {
+            return new State(this);
+        }
+    }
 }

src/test/java/io/searchbox/cluster/StateIntegrationTest.java

@@ -0,0 +1,53 @@
+package io.searchbox.cluster;
+
+import com.github.tlrx.elasticsearch.test.annotations.ElasticsearchIndex;
+import com.github.tlrx.elasticsearch.test.annotations.ElasticsearchNode;
+import com.github.tlrx.elasticsearch.test.support.junit.runners.ElasticsearchRunner;
+import com.google.gson.JsonObject;
+import io.searchbox.client.JestResult;
+import io.searchbox.common.AbstractIntegrationTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import java.io.IOException;
+
+import static junit.framework.Assert.*;
+
+/**
+ * @author cihat keser
+ */
+@RunWith(ElasticsearchRunner.class)
+@ElasticsearchNode
+public class StateIntegrationTest extends AbstractIntegrationTest {
+
+    @Test
+    @ElasticsearchIndex
+    public void clusterState() throws IOException {
+        JestResult result = client.execute(new State.Builder().build());
+        assertNotNull(result);
+        assertTrue(result.isSucceeded());
+
+        JsonObject resultJson = result.getJsonObject();
+        assertNotNull(resultJson);
+        assertNotNull(resultJson.getAsJsonObject("nodes"));
+        assertNotNull(resultJson.getAsJsonObject("routing_table"));
+        assertNotNull(resultJson.getAsJsonObject("metadata"));
+        assertNotNull(resultJson.getAsJsonObject("blocks"));
+    }
+
+    @Test
+    @ElasticsearchIndex
+    public void clusterStateWithFilterMetadata() throws IOException {
+        JestResult result = client.execute(new State.Builder().filterMetadata(true).build());
+        assertNotNull(result);
+        assertTrue(result.isSucceeded());
+
+        JsonObject resultJson = result.getJsonObject();
+        assertNotNull(resultJson);
+        assertNotNull(resultJson.getAsJsonObject("nodes"));
+        assertNotNull(resultJson.getAsJsonObject("routing_table"));
+        assertNull(resultJson.getAsJsonObject("metadata"));
+        assertNotNull(resultJson.getAsJsonObject("blocks"));
+    }
+
+}

src/test/java/io/searchbox/cluster/StateTest.java

@@ -0,0 +1,19 @@
+package io.searchbox.cluster;
+
+import io.searchbox.Action;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+/**
+ * @author cihat keser
+ */
+public class StateTest {
+
+    @Test
+    public void testUriGeneration() {
+        Action action = new State.Builder().build();
+        assertEquals("/_cluster/state", action.getURI());
+    }
+
+}