Initial Mongo/DocumentDB source Configuration and Client

Signed-off-by: Dinu John <[email protected]>
dinujoh · Mar 12, 2024 · 1b4c39f · 1b4c39f
1 parent 3408055
commit 1b4c39f
Show file tree

Hide file tree

Showing 5 changed files with 2 additions and 1 deletion.
diff --git a/...prepper-plugins/mongo-source/build.gradle → data-prepper-plugins/mongodb/build.gradle b/...prepper-plugins/mongo-source/build.gradle → data-prepper-plugins/mongodb/build.gradle
diff --git a/...r/plugins/mongo/client/MongoDBHelper.java → ...r/plugins/mongo/client/MongoDBHelper.java b/...r/plugins/mongo/client/MongoDBHelper.java → ...r/plugins/mongo/client/MongoDBHelper.java
diff --git a/...mongo/configuration/CollectionConfig.java → ...mongo/configuration/CollectionConfig.java b/...mongo/configuration/CollectionConfig.java → ...mongo/configuration/CollectionConfig.java
diff --git a/...go/configuration/MongoDBSourceConfig.java → ...go/configuration/MongoDBSourceConfig.java b/...go/configuration/MongoDBSourceConfig.java → ...go/configuration/MongoDBSourceConfig.java
@@ -22,6 +22,7 @@ public class MongoDBSourceConfig {
     private String trustStorePassword;
     @JsonProperty("credentials")
     private CredentialsConfig credentialsConfig;
+
     @JsonProperty("snapshot_fetch_size")
     private String snapshotFetchSize;
     @JsonProperty("read_preference")
@@ -34,7 +35,7 @@ public class MongoDBSourceConfig {
     private Boolean ssl;
     @JsonProperty("ssl_invalid_host_allowed")
     private Boolean sslInvalidHostAllowed;
-    @JsonProperty("directConnection")
+    @JsonProperty("direct_connection")
     private Boolean directConnection;
 
     public MongoDBSourceConfig() {

diff --git a/...ugins/mongo/client/MongoDBHelperTest.java → ...ugins/mongo/client/MongoDBHelperTest.java b/...ugins/mongo/client/MongoDBHelperTest.java → ...ugins/mongo/client/MongoDBHelperTest.java