Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-25895 Implement a Cluster Metrics JSON endpoint (addendum)

This commit is contained in:
Nick Dimiduk 2022-03-11 15:28:37 +01:00 committed by Nick Dimiduk
parent 36a5f86c50
commit f640b7fd27
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/test/java/org/apache/hadoop/hbase/master/http/TestApiV1ClusterMetricsResource.java
View File

@ -28,6 +28,7 @@ import java.util.function.Supplier;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.ConnectionRule; import org.apache.hadoop.hbase.ConnectionRule;
import org.apache.hadoop.hbase.HBaseClassTestRule; import org.apache.hadoop.hbase.HBaseClassTestRule;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.MiniClusterRule; import org.apache.hadoop.hbase.MiniClusterRule;
import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.ServerName;
@ -72,8 +73,9 @@ public class TestApiV1ClusterMetricsResource {
.build()) .build())
.setConfiguration(() -> { .setConfiguration(() -> {
// enable Master InfoServer and random port selection // enable Master InfoServer and random port selection
final Configuration conf = new Configuration(); final Configuration conf = HBaseConfiguration.create();
conf.setInt(HConstants.MASTER_INFO_PORT, 0); conf.setInt(HConstants.MASTER_INFO_PORT, 0);
conf.set("hbase.http.jersey.tracing.type", "ON_DEMAND");
return conf; return conf;
}) })
.build(); .build();
@ -148,6 +150,7 @@ public class TestApiV1ClusterMetricsResource {
public void testGetRoot() { public void testGetRoot() {
final String response = classRule.getTarget() final String response = classRule.getTarget()
.request(MediaType.APPLICATION_JSON_TYPE) .request(MediaType.APPLICATION_JSON_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class); .get(String.class);
assertThat(response, allOf( assertThat(response, allOf(
containsString("\"hbase_version\":"), containsString("\"hbase_version\":"),
@ -160,6 +163,7 @@ public class TestApiV1ClusterMetricsResource {
public void testGetRootHtml() { public void testGetRootHtml() {
assertThrows(NotAcceptableException.class, () -> classRule.getTarget() assertThrows(NotAcceptableException.class, () -> classRule.getTarget()
.request(MediaType.TEXT_HTML_TYPE) .request(MediaType.TEXT_HTML_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class)); .get(String.class));
} }
@ -168,6 +172,7 @@ public class TestApiV1ClusterMetricsResource {
final String response = classRule.getTarget() final String response = classRule.getTarget()
.path("live_servers") .path("live_servers")
.request(MediaType.APPLICATION_JSON_TYPE) .request(MediaType.APPLICATION_JSON_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class); .get(String.class);
assertThat(response, allOf( assertThat(response, allOf(
startsWith("{\"data\":["), startsWith("{\"data\":["),
@ -179,6 +184,7 @@ public class TestApiV1ClusterMetricsResource {
assertThrows(NotAcceptableException.class, () -> classRule.getTarget() assertThrows(NotAcceptableException.class, () -> classRule.getTarget()
.path("live_servers") .path("live_servers")
.request(MediaType.TEXT_HTML_TYPE) .request(MediaType.TEXT_HTML_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class)); .get(String.class));
} }
@ -187,6 +193,7 @@ public class TestApiV1ClusterMetricsResource {
final String response = classRule.getTarget() final String response = classRule.getTarget()
.path("dead_servers") .path("dead_servers")
.request(MediaType.APPLICATION_JSON_TYPE) .request(MediaType.APPLICATION_JSON_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class); .get(String.class);
assertThat(response, allOf( assertThat(response, allOf(
startsWith("{\"data\":["), startsWith("{\"data\":["),
@ -198,6 +205,7 @@ public class TestApiV1ClusterMetricsResource {
assertThrows(NotAcceptableException.class, () -> classRule.getTarget() assertThrows(NotAcceptableException.class, () -> classRule.getTarget()
.path("dead_servers") .path("dead_servers")
.request(MediaType.TEXT_HTML_TYPE) .request(MediaType.TEXT_HTML_TYPE)
.header("X-Jersey-Tracing-Accept", true)
.get(String.class)); .get(String.class));
} }
} }