Skip to content

Commit a5a700f

Browse files
razvanrazvan
committed
add "operations-kraft" test
1 parent f01244a commit a5a700f

15 files changed

Lines changed: 332 additions & 0 deletions

‎tests/templates/kuttl/operations-kraft/00-assert.yaml.j2‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestAssert
4+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
5+
---
6+
apiVersion: v1
7+
kind: ConfigMap
8+
metadata:
9+
name: vector-aggregator-discovery
10+
{% endif %}

‎tests/templates/kuttl/operations-kraft/00-install-vector-aggregator-discovery-configmap.yaml.j2‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
2+
---
3+
apiVersion: v1
4+
kind: ConfigMap
5+
metadata:
6+
name: vector-aggregator-discovery
7+
data:
8+
ADDRESS: {{ lookup('env', 'VECTOR_AGGREGATOR') }}
9+
{% endif %}

‎tests/templates/kuttl/operations-kraft/00-patch-ns.yaml.j2‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
{% if test_scenario['values']['openshift'] == 'true' %}
2+
# see https://github.com/stackabletech/issues/issues/566
3+
---
4+
apiVersion: kuttl.dev/v1beta1
5+
kind: TestStep
6+
commands:
7+
- script: kubectl patch namespace $NAMESPACE -p '{"metadata":{"labels":{"pod-security.kubernetes.io/enforce":"privileged"}}}'
8+
timeout: 120
9+
{% endif %}

‎tests/templates/kuttl/operations-kraft/20-assert.yaml.j2‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestAssert
4+
timeout: 300
5+
commands:
6+
- script: kubectl -n $NAMESPACE wait --for=condition=available kafkaclusters.kafka.stackable.tech/test-kafka --timeout 301s
7+
---
8+
apiVersion: apps/v1
9+
kind: StatefulSet
10+
metadata:
11+
name: test-kafka-broker-default
12+
status:
13+
readyReplicas: 3
14+
replicas: 3
15+
---
16+
apiVersion: apps/v1
17+
kind: StatefulSet
18+
metadata:
19+
name: test-kafka-controller-default
20+
status:
21+
readyReplicas: 3
22+
replicas: 3

‎tests/templates/kuttl/operations-kraft/20-install-kafka.yaml.j2‎

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestStep
4+
timeout: 300
5+
---
6+
apiVersion: kafka.stackable.tech/v1alpha1
7+
kind: KafkaCluster
8+
metadata:
9+
name: test-kafka
10+
spec:
11+
image:
12+
{% if test_scenario['values']['kafka-kraft'].find(",") > 0 %}
13+
custom: "{{ test_scenario['values']['kafka-kraft'].split(',')[1] }}"
14+
productVersion: "{{ test_scenario['values']['kafka-kraft'].split(',')[0] }}"
15+
{% else %}
16+
productVersion: "{{ test_scenario['values']['kafka-kraft'] }}"
17+
{% endif %}
18+
pullPolicy: IfNotPresent
19+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
20+
clusterConfig:
21+
vectorAggregatorConfigMapName: vector-aggregator-discovery
22+
{% endif %}
23+
controllers:
24+
config:
25+
logging:
26+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
27+
roleGroups:
28+
default:
29+
replicas: 3
30+
brokers:
31+
config:
32+
logging:
33+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
34+
roleGroups:
35+
default:
36+
replicas: 3

‎tests/templates/kuttl/operations-kraft/25-assert.yaml.j2‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestAssert
4+
timeout: 300
5+
commands:
6+
- script: kubectl -n $NAMESPACE wait --for=condition=reconciliationPaused kafkaclusters.kafka.stackable.tech/test-kafka --timeout 301s
7+
---
8+
apiVersion: apps/v1
9+
kind: StatefulSet
10+
metadata:
11+
name: test-kafka-broker-default
12+
status:
13+
replicas: 3
14+
---
15+
apiVersion: apps/v1
16+
kind: StatefulSet
17+
metadata:
18+
name: test-kafka-controller-default
19+
status:
20+
replicas: 3

‎tests/templates/kuttl/operations-kraft/25-pause-kafka.yaml.j2‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestStep
4+
timeout: 300
5+
---
6+
apiVersion: kafka.stackable.tech/v1alpha1
7+
kind: KafkaCluster
8+
metadata:
9+
name: test-kafka
10+
spec:
11+
image:
12+
{% if test_scenario['values']['kafka-kraft'].find(",") > 0 %}
13+
custom: "{{ test_scenario['values']['kafka-kraft'].split(',')[1] }}"
14+
productVersion: "{{ test_scenario['values']['kafka-kraft'].split(',')[0] }}"
15+
{% else %}
16+
productVersion: "{{ test_scenario['values']['kafka-kraft'] }}"
17+
{% endif %}
18+
pullPolicy: IfNotPresent
19+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
20+
clusterConfig:
21+
vectorAggregatorConfigMapName: vector-aggregator-discovery
22+
{% endif %}
23+
controllers:
24+
config:
25+
logging:
26+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
27+
roleGroups:
28+
default:
29+
replicas: 3
30+
brokers:
31+
config:
32+
logging:
33+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
34+
roleGroups:
35+
default:
36+
replicas: 3
37+
clusterOperation:
38+
stopped: false
39+
reconciliationPaused: true

‎tests/templates/kuttl/operations-kraft/30-assert.yaml.j2‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestAssert
4+
timeout: 300
5+
commands:
6+
- script: kubectl -n $NAMESPACE wait --for=condition=stopped kafkaclusters.kafka.stackable.tech/test-kafka --timeout 301s
7+
---
8+
apiVersion: apps/v1
9+
kind: StatefulSet
10+
metadata:
11+
name: test-kafka-broker-default
12+
status:
13+
replicas: 0
14+
---
15+
apiVersion: apps/v1
16+
kind: StatefulSet
17+
metadata:
18+
name: test-kafka-controller-default
19+
status:
20+
replicas: 0

‎tests/templates/kuttl/operations-kraft/30-stop-kafka.yaml.j2‎

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestStep
4+
timeout: 300
5+
---
6+
apiVersion: kafka.stackable.tech/v1alpha1
7+
kind: KafkaCluster
8+
metadata:
9+
name: test-kafka
10+
spec:
11+
image:
12+
{% if test_scenario['values']['kafka-kraft'].find(",") > 0 %}
13+
custom: "{{ test_scenario['values']['kafka-kraft'].split(',')[1] }}"
14+
productVersion: "{{ test_scenario['values']['kafka-kraft'].split(',')[0] }}"
15+
{% else %}
16+
productVersion: "{{ test_scenario['values']['kafka-kraft'] }}"
17+
{% endif %}
18+
pullPolicy: IfNotPresent
19+
{% if lookup('env', 'VECTOR_AGGREGATOR') %}
20+
clusterConfig:
21+
vectorAggregatorConfigMapName: vector-aggregator-discovery
22+
{% endif %}
23+
brokers:
24+
config:
25+
logging:
26+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
27+
roleGroups:
28+
default:
29+
replicas: 3
30+
controllers:
31+
config:
32+
logging:
33+
enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
34+
roleGroups:
35+
default:
36+
replicas: 3
37+
clusterOperation:
38+
stopped: true
39+
reconciliationPaused: false

‎tests/templates/kuttl/operations-kraft/50-assert.yaml.j2‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
---
2+
apiVersion: kuttl.dev/v1beta1
3+
kind: TestAssert
4+
timeout: 300
5+
commands:
6+
- script: kubectl -n $NAMESPACE wait --for=condition=available kafkaclusters.kafka.stackable.tech/test-kafka --timeout 301s
7+
---
8+
apiVersion: apps/v1
9+
kind: StatefulSet
10+
metadata:
11+
name: test-kafka-broker-default
12+
status:
13+
readyReplicas: 3
14+
replicas: 3
15+
apiVersion: apps/v1
16+
kind: StatefulSet
17+
metadata:
18+
name: test-kafka-controller-default
19+
status:
20+
readyReplicas: 3
21+
replicas: 3

0 commit comments

Comments
 (0)