Allow using custom tests (#766)

Author: lfrancke

tests/templates/kuttl/cluster-operation/20-install-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka-latest'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-latest'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-latest'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}

tests/templates/kuttl/cluster-operation/30-stop-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka-latest'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-latest'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-latest'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}

tests/templates/kuttl/cluster-operation/40-pause-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka-latest'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-latest'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-latest'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}

tests/templates/kuttl/cluster-operation/50-restart-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka-latest'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-latest'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-latest'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
+{% endif %}
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
     vectorAggregatorConfigMapName: vector-aggregator-discovery

tests/templates/kuttl/configuration/20-install-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka-latest'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka-latest'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka-latest'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}

tests/templates/kuttl/delete-rolegroup/02-install-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}

tests/templates/kuttl/delete-rolegroup/03-delete-secondary.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka'] }}"
+{% endif %}
   clusterConfig:
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
     vectorAggregatorConfigMapName: vector-aggregator-discovery

tests/templates/kuttl/logging/04-install-kafka.yaml.j2

@@ -25,7 +25,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
     tls:

tests/templates/kuttl/smoke/30-install-kafka.yaml.j2

@@ -9,7 +9,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
     tls:

tests/templates/kuttl/tls/20-install-kafka.yaml.j2

@@ -37,7 +37,12 @@ metadata:
   name: test-kafka
 spec:
   image:
+{% if test_scenario['values']['kafka'].find(",") > 0 %}
+    custom: "{{ test_scenario['values']['kafka'].split(',')[1] }}"
+    productVersion: "{{ test_scenario['values']['kafka'].split(',')[0] }}"
+{% else %}
     productVersion: "{{ test_scenario['values']['kafka'] }}"
+{% endif %}
     pullPolicy: IfNotPresent
   clusterConfig:
 {% if test_scenario['values']['use-client-auth-tls'] == 'true' %}