honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-03-09 14:34:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: added test for http input querying api other than _search

Browse Source 
Original commit: elastic/x-pack-elasticsearch@ebb1d802c9
This commit is contained in:
Martijn van Groningen 2015-04-24 12:45:35 +02:00
parent 3e882fce7d
commit e1c163dba4
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/test/java/org/elasticsearch/watcher/test/integration/HttpInputIntegrationTest.java
View File

@ -27,7 +27,7 @@ import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
import static org.elasticsearch.index.query.QueryBuilders.matchQuery;
import static org.elasticsearch.index.query.QueryBuilders.termQuery;
import static org.elasticsearch.test.hamcrest.ElasticsearchAssertions.assertHitCount;
import static org.elasticsearch.watcher.actions.ActionBuilders.indexAction;
import static org.elasticsearch.watcher.actions.ActionBuilders.loggingAction;
import static org.elasticsearch.watcher.client.WatchSourceBuilders.watchBuilder;
import static org.elasticsearch.watcher.condition.ConditionBuilders.scriptCondition;
import static org.elasticsearch.watcher.input.InputBuilders.httpInput;
@ -61,7 +61,27 @@ public class HttpInputIntegrationTest extends AbstractWatcherIntegrationTests {
.body(jsonBuilder().startObject().field("size", 1).endObject())
.auth(shieldEnabled() ? new BasicAuth("test", "changeme") : null)))
.condition(scriptCondition("ctx.payload.hits.total == 1"))
.addAction("_id", indexAction("idx", "action")))
.addAction("_id", loggingAction("watch [{{ctx.watch_id}}] matched")))
.get();
if (timeWarped()) {
timeWarp().scheduler().trigger("_name");
refresh();
}
assertWatchWithMinimumPerformedActionsCount("_name", 1, false);
}
@Test
public void testHttpInput_clusterStats() throws Exception {
InetSocketAddress address = internalTestCluster().httpAddresses()[0];
watcherClient().preparePutWatch("_name")
.setSource(watchBuilder()
.trigger(schedule(interval("5s")))
.input(httpInput(HttpRequestTemplate.builder(address.getHostName(), address.getPort())
.path("/_cluster/stats")
.auth(shieldEnabled() ? new BasicAuth("test", "changeme") : null)))
.condition(scriptCondition("ctx.payload.nodes.count.total > 1"))
.addAction("_id", loggingAction("watch [{{ctx.watch_id}}] matched")))
.get();
if (timeWarped()) {