Update consul-values job

Author: thejsj

ansible/consul-values.yml

@@ -2,33 +2,6 @@
 - hosts: consul
   vars_files:
     - "group_vars/alpha-consul.yml"
-  tasks:
-    - name: make sure httplib2 is installed
-      become: true
-      apt: package=python-httplib2 state=present
-
-    - name: put values into consul
-      run_once: true
-      when: write_values is defined
-      uri:
-        method=PUT
-        url=http://{{ ansible_default_ipv4.address }}:8500/v1/kv/{{ item.key }}
-        body="{{ item.value }}"
-      with_items: "{{ consul_seed }}"
-
-    - name: get values from consul
-      tags: consul_values
-      run_once: true
-      when: read_values is defined
-      uri:
-        method=GET
-        url=http://{{ ansible_default_ipv4.address }}:8500/v1/kv/{{ item.key }}
-      with_items: "{{ consul_seed }}"
-      register: values
-
-    - name: print values to screen
-      tags: consul_values
-      run_once: true
-      when: read_values is defined
-      debug: msg="{{ item.item.key }}" -> "{{ item.json[0].Value | b64decode }}"
-      with_items: "{{ values.results }}"
+    - "group_vars/alpha-consul-values.yml"
+  roles:
+    - role: k8-job

ansible/group_vars/all.yml

@@ -14,6 +14,7 @@ docker_client_root: "{{ secrets_root }}/docker-client/"
 config_maps_path: "{{ opts_root }}/configMaps"
 services_path: "{{ opts_root }}/services"
 deployments_path: "{{ opts_root }}/deployments"
+jobs_path: "{{ opts_root }}/jobs"
 cron_jobs_path: "{{ opts_root }}/crons"
 volumes_path: "{{ opts_root }}/volumes"
 daemon_sets_path: "{{ opts_root }}/daemonSets"

ansible/group_vars/alpha-consul-values.yml

@@ -0,0 +1,9 @@
+name: consul-update
+
+container_image: tutum/curl
+container_tag: latest
+
+advance_arg: true
+
+container_run_args: >
+  {% for item in consul_seed %} curl -X PUT http://consul:8500/v1/kv/{{ item.key }} --data {{ item.value }} && {% endfor %} echo Finished

ansible/roles/k8-job/tasks/main.yml

@@ -0,0 +1,10 @@
+---
+- name: create job folder
+  file:
+    state: directory
+    path: "{{ jobs_path }}"
+
+- name: create job yaml
+  template:
+    dest: "{{ jobs_path }}/{{ name }}.yml"
+    src: job.yml

ansible/roles/k8-job/templates/job.yml

@@ -0,0 +1,94 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: {{ name }}
+spec:
+  template:
+    metadata:
+      labels:
+        app: {{ name }}
+    spec:
+      imagePullSecrets:
+        - name: {{ image_pull_secret_name }}
+      hostname: {{ name }}
+      restartPolicy: OnFailure
+      containers:
+        - image: {{ container_image }}:{{ container_tag }}
+          imagePullPolicy: Always
+          name: {{ name }}
+          resources:
+            requests:
+              cpu: "250m"
+              memory: "500M"
+            limits:
+              cpu: "1550m"
+              memory: {{ memory_hard_limit | default("1500M") }}
+{% if post_start_command is defined %}
+          lifecycle:
+            postStart:
+              exec:
+                command: ["/bin/bash", "-c", "{{ post_start_command }}"]
+{% endif %}
+{% if container_run_args != '' %}
+          args:
+{% if advance_arg is defined and advance_arg == true %}
+            - bash
+            - -c
+            - "{{ container_run_args }}"
+{% else %}
+{% for arg in container_run_args.split(' ') %}
+            - {{ arg }}
+{% endfor %}
+{% endif %}
+{% endif %}
+{% if container_envs is defined %}
+          env:
+{% for env in container_envs %}
+{% if (env.value is defined and env.value != 'ansible_undefined') or env.valueFrom is defined %}
+            - name: {{ env.name }}
+{% if env.value is defined %}
+              value: "{{ env.value }}"
+{% endif %}
+{% if env.valueFrom is defined %}
+              valueFrom:
+                fieldRef:
+                  fieldPath: {{ env.valueFrom }}
+{% endif %}
+{% endif %}
+{% endfor %}
+{% endif %}
+{% if add_capabilities is defined %}
+          securityContext:
+            capabilities:
+              add:
+{% for cap in add_capabilities %}
+              - {{ cap }}
+{% endfor %}
+{% endif %}
+{% if hosted_ports is defined %}
+          ports:
+{% for port in hosted_ports %}
+            - containerPort: {{ port }}
+{% endfor %}
+{% endif %}
+{% if volume_mounts is defined %}
+          volumeMounts:
+{% for volume in volume_mounts %}
+            - name: {{ volume.name }}
+              mountPath: {{ volume.path }}
+{% endfor %}
+{% endif %}
+{% if volume_mounts is defined %}
+      volumes:
+{% for volume in volume_mounts %}
+        - name: {{ volume.name }}
+{% if volume.kind == "configMap" %}
+          configMap:
+            name: {{ volume.name }}
+{% endif %}
+{% if volume.kind == "persistent" %}
+          persistentVolumeClaim:
+            claimName: {{ volume.name }}
+{% endif %}
+{% endfor %}
+{% endif %}