honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: use put watch api to insert watches 

test: verify that the exection queue size is 0 when Watcher isn't running

Original commit: elastic/x-pack-elasticsearch@ea16d066e5
This commit is contained in:
Martijn van Groningen 2015-04-28 15:26:20 +02:00
parent 87e3a6a41d
commit 735369b5f4
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/test/java/org/elasticsearch/watcher/test/integration/NoMasterNodeTests.java
View File

@ -24,6 +24,7 @@ import org.elasticsearch.test.junit.annotations.TestLogging;
import org.elasticsearch.watcher.WatcherService; import org.elasticsearch.watcher.WatcherService;
import org.elasticsearch.watcher.client.WatchSourceBuilder; import org.elasticsearch.watcher.client.WatchSourceBuilder;
import org.elasticsearch.watcher.client.WatchSourceBuilders; import org.elasticsearch.watcher.client.WatchSourceBuilders;
import org.elasticsearch.watcher.execution.ExecutionService;
import org.elasticsearch.watcher.test.AbstractWatcherIntegrationTests; import org.elasticsearch.watcher.test.AbstractWatcherIntegrationTests;
import org.elasticsearch.watcher.test.WatcherTestUtils; import org.elasticsearch.watcher.test.WatcherTestUtils;
import org.elasticsearch.watcher.transport.actions.delete.DeleteWatchResponse; import org.elasticsearch.watcher.transport.actions.delete.DeleteWatchResponse;
@ -181,11 +182,12 @@ public class NoMasterNodeTests extends AbstractWatcherIntegrationTests {
// watcher starts in the background, it can happen we get here too soon, so wait until watcher has started. // watcher starts in the background, it can happen we get here too soon, so wait until watcher has started.
ensureWatcherStarted(false); ensureWatcherStarted(false);
ensureLicenseEnabled();
for (int i = 1; i <= numberOfWatches; i++) { for (int i = 1; i <= numberOfWatches; i++) {
String watchName = "watch" + i; String watchName = "watch" + i;
SearchRequest searchRequest = WatcherTestUtils.newInputSearchRequest("my-index").source(searchSource().query(termQuery("field", "value"))); SearchRequest searchRequest = WatcherTestUtils.newInputSearchRequest("my-index").source(searchSource().query(termQuery("field", "value")));
BytesReference watchSource = createWatchSource("0/5 * * * * ? *", searchRequest, "ctx.payload.hits.total == 1"); BytesReference watchSource = createWatchSource("0/5 * * * * ? *", searchRequest, "ctx.payload.hits.total == 1");
watchService().putWatch(watchName, watchSource); watcherClient().preparePutWatch(watchName).setSource(watchSource).get();
} }
ensureGreen(); ensureGreen();
@ -223,6 +225,9 @@ public class NoMasterNodeTests extends AbstractWatcherIntegrationTests {
for (WatcherService watcherService : internalTestCluster().getInstances(WatcherService.class)) { for (WatcherService watcherService : internalTestCluster().getInstances(WatcherService.class)) {
assertThat(watcherService.state(), is(WatcherService.State.STOPPED)); assertThat(watcherService.state(), is(WatcherService.State.STOPPED));
} }
for (ExecutionService executionService : internalTestCluster().getInstances(ExecutionService.class)) {
assertThat(executionService.queueSize(), equalTo(0l));
}
} }
private void startElectedMasterNodeAndWait() throws Exception { private void startElectedMasterNodeAndWait() throws Exception {