Ingest - types testing

ci/it/configs/quesma-ingest-types.yml.template

@@ -0,0 +1,48 @@
+frontendConnectors:
+  - name: elastic-ingest
+    type: elasticsearch-fe-ingest
+    config:
+      listenPort: 8080
+  - name: elastic-query
+    type: elasticsearch-fe-query
+    config:
+      listenPort: 8080
+backendConnectors:
+  - name: my-minimal-elasticsearch
+    type: elasticsearch
+    config:
+      url: "http://{{ .elasticsearch_host }}:{{ .elasticsearch_port }}"
+      user: elastic
+      password: quesmaquesma
+  - name: my-clickhouse-instance
+    type: clickhouse-os
+    config:
+      url: clickhouse://{{ .clickhouse_host }}:{{ .clickhouse_port }}
+ingestStatistics: true
+processors:
+  - name: my-query-processor
+    type: quesma-v1-processor-query
+    config:
+      indexes:
+        "*":
+          target:
+            - my-clickhouse-instance
+
+  - name: my-ingest-processor
+    type: quesma-v1-processor-ingest
+    config:
+      indexes:
+        "*":
+          target:
+            - my-clickhouse-instance
+
+pipelines:
+  - name: my-elasticsearch-proxy-read
+    frontendConnectors: [ elastic-query ]
+    processors: [ my-query-processor ]
+    backendConnectors: [ my-minimal-elasticsearch, my-clickhouse-instance ]
+  - name: my-elasticsearch-proxy-write
+    frontendConnectors: [ elastic-ingest ]
+    processors: [ my-ingest-processor ]
+    backendConnectors: [ my-minimal-elasticsearch, my-clickhouse-instance ]
+

ci/it/configs/quesma-ingest.yml.template

@@ -101,7 +101,7 @@ processors:
             - my-clickhouse-instance
         "*":
           target:
-            - my-minimal-elasticsearch
+            - my-clickhouse-instance
   - name: my-ingest-processor
     type: quesma-v1-processor-ingest
     config:
@@ -179,7 +179,8 @@ processors:
             - my-clickhouse-instance
         "*":
           target:
-            - my-minimal-elasticsearch
+            - my-clickhouse-instance
+
 pipelines:
   - name: my-elasticsearch-proxy-read
     frontendConnectors: [ elastic-query ]

ci/it/integration_test.go

@@ -61,3 +61,8 @@ func TestABTestcase(t *testing.T) {
 	testCase := testcases.NewABTestcase()
 	runIntegrationTest(t, testCase)
 }
+
+func TestIngestTypesTestcase(t *testing.T) {
+	testCase := testcases.NewIngestTypesTestcase()
+	runIntegrationTest(t, testCase)
+}