(refactor): Updating kafka broker pod failure experiment (#1095)

Signed-off-by: shubhamchaudhary <[email protected]>

Author: ispeakc0de

chaoslib/chaoskube/README.md

@@ -1,3 +1,3 @@
 ## Note 
 
-The chaoskube library is not supported by litmuschaos any more. It will be left here, because it can be used if the chaosServiceAccount has cluster-scope. As of version 0.8 chaosexperiments are namespace-scoped
+The chaoskube library is not supported by litmuschaos any more. It will be left here, because it can be used if the chaosServiceAccount has cluster-scope. As of version 1.0 the pod-delete (and other app-level) chaosexperiments are namespace-scoped

chaoslib/powerfulseal/pod_failure_by_powerfulseal.yml

@@ -7,15 +7,15 @@
 
     - name: Setup powerfulseal to initiate random pod chaos 
       shell:
-        kubectl apply -f powerfulseal.yml -n {{ a_ns }}
+        kubectl apply -f powerfulseal.yml -n {{ app_ns }}
       args:
         executable: /bin/bash
       register: deployment_result
       failed_when: "deployment_result.rc != 0"
 
     - name: Confirm that powerfulseal pod is running
       shell: >
-        kubectl get pod -l name=powerfulseal --no-headers -n {{ a_ns }}
+        kubectl get pod -l name=powerfulseal --no-headers -n {{ app_ns }}
       args:
         executable: /bin/bash
       register: result
@@ -28,7 +28,7 @@
 
     - name: Tear down the powerfulseal deployment
       shell: 
-        kubectl delete -f powerfulseal.yml -n {{ a_ns }}
+        kubectl delete -f powerfulseal.yml -n {{ app_ns }}
       args:
         executable: /bin/bash
       register: result
@@ -50,7 +50,7 @@
 
         - name: Tear down the powerfulseal deployment
           shell: >
-            kubectl delete -f powerfulseal.yml -n {{ a_ns }}
+            kubectl delete -f powerfulseal.yml -n {{ app_ns }}
           args:
             executable: /bin/bash
           when: deployment_result.rc == 0

chaoslib/powerfulseal/powerfulseal.j2

@@ -13,8 +13,8 @@ data:
       - name: "delete random pods in default namespace"
         match:
           - labels:
-              namespace: {{ a_ns }}
-              selector: {{ a_label }}
+              namespace: {{ app_ns }}
+              selector: {{ app_label }}
         filters:
           - randomSample:
               size: 1

executor/README.md

@@ -127,12 +127,8 @@
 
 ### Limitations
 
--   Executor is currently unable to parse more than one configmap.
-
 -   The name of file which contains data for configmap in experimentCR should be parameters.yml
 
 -   The configmap is mounted in this default directory: /mnt/ 
 
--   Executor is currently unable to parse more than one secret.
-
 -   The secret is mounted in this default directory: /tmp/ 

experiments/kafka/kafka-broker-pod-failure/chaosutil.j2

@@ -1,6 +1,4 @@
-{% if c_lib is defined and c_lib == 'chaoskube' %}
-   c_util: /chaoslib/chaoskube/pod_failure_by_chaoskube.yml
-{% elif c_lib is defined and c_lib == 'powerfulseal' %}
+{% if c_lib is defined and c_lib == 'powerfulseal' %}
    c_util: /chaoslib/powerfulseal/pod_failure_by_powerfulseal.yml
 {% else %}
    c_util: /chaoslib/litmus/pod_failure_by_litmus.yml

experiments/kafka/kafka-broker-pod-failure/kafka-broker-pod-failure-ansible-logic.yml

@@ -8,6 +8,7 @@
     c_interval: "{{ lookup('env','CHAOS_INTERVAL') }}"
     c_force: "{{ lookup('env','FORCE') }}"
     c_lib: "{{ lookup('env','LIB') }}"
+    c_svc_acc: "{{ lookup('env','CHAOS_SERVICE_ACCOUNT') }}"
     kill_count: "{{ lookup('env','KILL_COUNT') }}"
     kafka_instance: "{{ lookup('env','KAFKA_INSTANCE_NAME') }}"
     kafka_ns: "{{ lookup('env','KAFKA_NAMESPACE') }}"
@@ -67,7 +68,6 @@
           vars:
             app_ns: "{{ kafka_ns }}"
             app_label: "{{ kafka_label }}"
-
             # derived from the 'kafka_broker_util' task
             app_pod_name: "{{ kafka_broker }}" 
 

utils/apps/kafka/kafka_cluster_health.yml

@@ -12,8 +12,8 @@
   vars:
     delay: 1
     retries: 60
-    a_ns: "{{ zk_ns }}"
-    a_label: "{{ zk_label }}"
+    app_ns: "{{ zk_ns }}"
+    app_label: "{{ zk_label }}"
 
 - name: Obtain pods name of any one of the zookeeper pods
   shell: >
@@ -51,19 +51,19 @@
 
   when: "kafka_instance is defined and kafka_instance != ''"
 
-- block: 
-    - name: Derive the available kafka brokers from zookeeper
-      shell: >
-        kubectl exec {{ zk_pod_name }} -n {{ zk_ns }} bash 
-        -- zkCli.sh -server {{ zk_service }}:{{ zk_port }} 
-        ls /brokers/ids | tail -n 1 | tr -d '[],' | tr ' ' '\n'  | wc -l
-      args: 
-        executable: /bin/bash
-      register: kafka_available_brokers
+# - block: 
+#     - name: Derive the available kafka brokers from zookeeper
+#       shell: >
+#         kubectl exec {{ zk_pod_name }} -n {{ zk_ns }} bash 
+#         -- zkCli.sh -server {{ zk_service }}:{{ zk_port }} 
+#         ls /brokers/ids | tail -n 1 | tr -d '[],' | tr ' ' '\n'  | wc -l
+#       args: 
+#         executable: /bin/bash
+#       register: kafka_available_brokers
 
-    - name: Check whether all kafka brokers are alive
-      debug: 
-        msg: "All Kafka brokers are alive"
-      failed_when: "kafka_sts_replicas.stdout != kafka_available_brokers.stdout"
+#     - name: Check whether all kafka brokers are alive
+#       debug: 
+#         msg: "All Kafka brokers are alive"
+#       failed_when: "kafka_sts_replicas.stdout != kafka_available_brokers.stdout"
 
-  when: "kafka_instance is not defined or kafka_instance == ''"
+#   when: "kafka_instance is not defined or kafka_instance == ''"