From 071ceeab31f29982d28a90692fa023e46b479e4f Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 19 Oct 2022 18:08:10 +0200 Subject: [PATCH 1/2] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Minio Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 82cec34c6..fdae4ece6 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -85,7 +85,8 @@ public enum KameletPrefixSchemeEnum { kubernetes_pods("kubernetes-pods", "kubernetes-pods"), log("log", "log"), mail("mail", "imaps"), - mariadb("mariadb", "sql"); + mariadb("mariadb", "sql"), + minio("minio", "minio"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 7355db88f..65ad61194 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -270,5 +270,9 @@ void testSupportedHeaders() throws Exception { assertEquals(0, headersMariaDBSource.size()); List headersMariaDBSink= catalog.getKameletSupportedHeaders("mariadb-sink"); assertEquals(8, headersMariaDBSink.size()); + List headersMinioSource= catalog.getKameletSupportedHeaders("minio-source"); + assertEquals(14, headersMinioSource.size()); + List headersMinioSink= catalog.getKameletSupportedHeaders("minio-sink"); + assertEquals(21, headersMinioSink.size()); } } From d2a978de54f0dad5c9ac029dd5e31dfe60190100 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 19 Oct 2022 18:17:05 +0200 Subject: [PATCH 2/2] Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB Signed-off-by: Andrea Cosentino --- .../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++- .../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index fdae4ece6..4562db9ca 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -86,7 +86,9 @@ public enum KameletPrefixSchemeEnum { log("log", "log"), mail("mail", "imaps"), mariadb("mariadb", "sql"), - minio("minio", "minio"); + minio("minio", "minio"), + mongodb_changes_stream("mongodb-changes-stream", "mongodb"), + mongodb("mongodb", "mongodb"); public final String name; public final String scheme; diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index 65ad61194..cb8944806 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -274,5 +274,11 @@ void testSupportedHeaders() throws Exception { assertEquals(14, headersMinioSource.size()); List headersMinioSink= catalog.getKameletSupportedHeaders("minio-sink"); assertEquals(21, headersMinioSink.size()); + List headersMongodbChangesStreamSource= catalog.getKameletSupportedHeaders("mongodb-changes-stream-source"); + assertEquals(3, headersMongodbChangesStreamSource.size()); + List headersMongoDbSink= catalog.getKameletSupportedHeaders("mongodb-sink"); + assertEquals(12, headersMongoDbSink.size()); + List headersMongoDbSource= catalog.getKameletSupportedHeaders("mongodb-source"); + assertEquals(3, headersMongoDbSource.size()); } }