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

test: LocalExporterTests should wait for exporters to be started 

Original commit: elastic/x-pack-elasticsearch@978933f9d6
This commit is contained in:
jaymode 2016-12-07 09:22:05 -05:00
parent fba54d02d7
commit 714bf929af
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/exporter/local/LocalExporterTests.java
View File

@ -12,6 +12,7 @@ import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.cluster.ClusterState; import org.elasticsearch.cluster.ClusterState;
import org.elasticsearch.cluster.health.ClusterHealthStatus; import org.elasticsearch.cluster.health.ClusterHealthStatus;
import org.elasticsearch.cluster.node.DiscoveryNode; import org.elasticsearch.cluster.node.DiscoveryNode;
import org.elasticsearch.common.component.Lifecycle.State;
import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHit;
import org.elasticsearch.test.ESIntegTestCase.ClusterScope; import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
@ -178,6 +179,8 @@ public class LocalExporterTests extends MonitoringIntegTestCase {
private void export(Collection<MonitoringDoc> docs) throws Exception { private void export(Collection<MonitoringDoc> docs) throws Exception {
Exporters exporters = internalCluster().getInstance(Exporters.class); Exporters exporters = internalCluster().getInstance(Exporters.class);
assertThat(exporters, notNullValue()); assertThat(exporters, notNullValue());
// make sure exporters has been started, otherwise we might miss some of the exporters
assertBusy(() -> assertEquals(State.STARTED, exporters.lifecycleState()));
// Wait for exporting bulks to be ready to export // Wait for exporting bulks to be ready to export
assertBusy(() -> exporters.forEach(exporter -> assertThat(exporter.openBulk(), notNullValue()))); assertBusy(() -> exporters.forEach(exporter -> assertThat(exporter.openBulk(), notNullValue())));