LC-519: move OpenSearchIndexer to be its own plugin.

lucille-core/src/main/java/com/kmwllc/lucille/indexer/IndexerFactory.java

@@ -41,8 +41,6 @@ public static Indexer fromConfig(Config config, IndexerMessenger messenger, bool
     // handle type class instantiation or throw exception for unknown type
     if (typeName.equalsIgnoreCase("Solr")) {
       return new SolrIndexer(config, messenger, bypass, metricsPrefix);
-    } else if (typeName.equalsIgnoreCase("OpenSearch")) {
-      return new OpenSearchIndexer(config, messenger, bypass, metricsPrefix);
     } else if (typeName.equalsIgnoreCase("Elasticsearch")) {
       return new ElasticsearchIndexer(config, messenger, bypass, metricsPrefix);
     } else if (typeName.equalsIgnoreCase("CSV")) {

lucille-core/src/test/java/com/kmwllc/lucille/indexer/IndexerFactoryTest.java

@@ -38,14 +38,6 @@ public void testFromInvalidTypeConfig() throws Exception {
     Assert.assertTrue(exception.getMessage().contains("Unknown indexer.type configuration of:"));
   }
 
-  @Test
-  public void testFromValidTypeConfigOpen() throws Exception {
-    TestMessenger messenger = new TestMessenger();
-    Config config = ConfigFactory.load("IndexerFactoryTest/config_valid_type_open.conf");
-    Indexer indexer = IndexerFactory.fromConfig(config, messenger, true, "testing");
-    Assert.assertTrue(indexer instanceof OpenSearchIndexer);
-  }
-
   @Test
   public void testFromValidTypeConfigElastic() throws Exception {
     TestMessenger messenger = new TestMessenger();

lucille-plugins/lucille-opensearch/pom.xml

@@ -0,0 +1,63 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+      <groupId>com.kmwllc</groupId>
+      <artifactId>lucille-plugins</artifactId>
+      <version>0.2.4-SNAPSHOT</version>
+      <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>lucille-opensearch</artifactId>
+    <packaging>jar</packaging>
+    <name>Lucille Plugins: Lucille OpenSearch</name>
+
+    <dependencies>
+        <dependency>
+          <groupId>com.kmwllc</groupId>
+          <artifactId>lucille-core</artifactId>
+          <version>${project.version}</version>
+          <scope>provided</scope>
+        </dependency>
+    </dependencies>
+
+ <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-shade-plugin</artifactId>
+        <version>3.4.1</version>
+        <executions>
+          <execution>
+            <phase>package</phase>
+            <goals>
+              <goal>shade</goal>
+            </goals>
+            <configuration>
+              <finalName>${project.artifactId}-plugin</finalName>
+              <createDependencyReducedPom>false</createDependencyReducedPom>
+              <filters>
+                <filter>
+                  <artifact>*:*</artifact>
+                  <excludes>
+                    <exclude>META-INF/LICENSE</exclude>
+                    <exclude>META-INF/*.SF</exclude>
+                    <exclude>META-INF/*.DSA</exclude>
+                    <exclude>META-INF/*.RSA</exclude>
+                    <exclude>log4j2.properties</exclude>
+                  </excludes>
+                </filter>
+              </filters>
+              <transformers>
+                <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+              </transformers>
+            </configuration>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+</project>

lucille-core/src/main/java/com/kmwllc/lucille/indexer/OpenSearchIndexer.java → lucille-plugins/lucille-opensearch/src/main/java/com/kmwllc/lucille/opensearch/indexer/OpenSearchIndexer.java

@@ -1,14 +1,12 @@
-package com.kmwllc.lucille.indexer;
+package com.kmwllc.lucille.opensearch.indexer;
 
 import com.kmwllc.lucille.core.Document;
 import com.kmwllc.lucille.core.Indexer;
 import com.kmwllc.lucille.core.IndexerException;
 import com.kmwllc.lucille.core.KafkaDocument;
 import com.kmwllc.lucille.message.IndexerMessenger;
-import com.kmwllc.lucille.message.KafkaIndexerMessenger;
-import com.kmwllc.lucille.util.OpenSearchUtils;
+import com.kmwllc.lucille.opensearch.util.OpenSearchUtils;
 import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -20,7 +18,6 @@
 import org.opensearch.client.opensearch.core.bulk.BulkResponseItem;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import sun.misc.Signal;
 
 
 public class OpenSearchIndexer extends Indexer {

lucille-core/src/main/java/com/kmwllc/lucille/util/OpenSearchUtils.java → lucille-plugins/lucille-opensearch/src/main/java/com/kmwllc/lucille/opensearch/util/OpenSearchUtils.java

@@ -1,6 +1,6 @@
-package com.kmwllc.lucille.util;
+package com.kmwllc.lucille.opensearch.util;
 
-import com.kmwllc.lucille.indexer.OpenSearchIndexer;
+import com.kmwllc.lucille.opensearch.indexer.OpenSearchIndexer;
 import com.typesafe.config.Config;
 import java.net.URI;
 import java.security.KeyManagementException;

lucille-core/src/test/java/com/kmwllc/lucille/indexer/OpenSearchIndexerTest.java → lucille-plugins/lucille-opensearch/src/test/java/com/kmwllc/lucille/opensearch/indexer/OpenSearchIndexerTest.java

@@ -1,4 +1,4 @@
-package com.kmwllc.lucille.indexer;
+package com.kmwllc.lucille.opensearch.indexer;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertThrows;

lucille-plugins/pom.xml

@@ -22,6 +22,7 @@
     <module>lucille-parquet</module>
     <module>lucille-tika</module>
     <module>lucille-ocr</module>
+    <module>lucille-opensearch</module>
   </modules>
 
   <dependencies>