diff options
author | Robert Newson <rnewson@apache.org> | 2023-04-20 23:50:54 +0100 |
---|---|---|
committer | Robert Newson <rnewson@apache.org> | 2023-04-22 11:20:02 +0100 |
commit | 2192dc7a9969e5cd0bf6643445116ee508bbde28 (patch) | |
tree | 826786c541a13fae5555b813c86a2c31b0e9a55a | |
parent | 47f7216b552816fecee2da8785d2055040611592 (diff) | |
download | couchdb-2192dc7a9969e5cd0bf6643445116ee508bbde28.tar.gz |
more tests
-rw-r--r-- | nouveau/src/test/java/org/apache/couchdb/nouveau/health/AnalyzeHealthCheckTest.java | 29 | ||||
-rw-r--r-- | nouveau/src/test/java/org/apache/couchdb/nouveau/health/IndexHealthCheckTest.java | 51 |
2 files changed, 80 insertions, 0 deletions
diff --git a/nouveau/src/test/java/org/apache/couchdb/nouveau/health/AnalyzeHealthCheckTest.java b/nouveau/src/test/java/org/apache/couchdb/nouveau/health/AnalyzeHealthCheckTest.java new file mode 100644 index 000000000..8f39b3f39 --- /dev/null +++ b/nouveau/src/test/java/org/apache/couchdb/nouveau/health/AnalyzeHealthCheckTest.java @@ -0,0 +1,29 @@ +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package org.apache.couchdb.nouveau.health; +import static org.junit.jupiter.api.Assertions.assertTrue; + +import org.apache.couchdb.nouveau.resources.AnalyzeResource; +import org.junit.jupiter.api.Test; + +public class AnalyzeHealthCheckTest { + + @Test + public void testAnalyzeHealthCheck() throws Exception { + var resource = new AnalyzeResource(); + var check = new AnalyzeHealthCheck(resource); + assertTrue(check.check().isHealthy()); + } + +} diff --git a/nouveau/src/test/java/org/apache/couchdb/nouveau/health/IndexHealthCheckTest.java b/nouveau/src/test/java/org/apache/couchdb/nouveau/health/IndexHealthCheckTest.java new file mode 100644 index 000000000..42a3626d6 --- /dev/null +++ b/nouveau/src/test/java/org/apache/couchdb/nouveau/health/IndexHealthCheckTest.java @@ -0,0 +1,51 @@ +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package org.apache.couchdb.nouveau.health; + +import static org.junit.jupiter.api.Assertions.assertTrue; + +import java.nio.file.Path; +import java.util.concurrent.Executors; + +import org.apache.couchdb.nouveau.core.IndexManager; +import org.apache.couchdb.nouveau.resources.IndexResource; +import org.apache.lucene.search.SearcherFactory; +import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.io.TempDir; + +import com.codahale.metrics.MetricRegistry; +import com.fasterxml.jackson.databind.ObjectMapper; + +public class IndexHealthCheckTest { + + @Test + public void testIndexHealthCheck(@TempDir final Path tempDir) throws Exception { + var scheduler = Executors.newSingleThreadScheduledExecutor(); + var manager = new IndexManager(); + manager.setObjectMapper(new ObjectMapper()); + manager.setMetricRegistry(new MetricRegistry()); + manager.setRootDir(tempDir); + manager.setScheduler(scheduler); + manager.start(); + try { + var resource = new IndexResource(manager, new SearcherFactory()); + var check = new IndexHealthCheck(resource); + assertTrue(check.check().isHealthy()); + } finally { + scheduler.shutdown(); + manager.stop(); + } + } + +} |