Add telegraf user to haproxy group

molecule/default/files/ansible-inputs.conf

@@ -11,6 +11,9 @@
 
 [[inputs.diskio]]
 
+[[inputs.haproxy]]
+  servers = ["/run/haproxy/admin.sock"]
+
 [[inputs.kernel]]
 
 [[inputs.mem]]

molecule/default/inventory/group_vars/all.yml

@@ -8,6 +8,9 @@ telegraf_group_inputs:
   filestat:
     files:
       - "/var/log/**.log"
+  haproxy:
+    servers:
+      - "/run/haproxy/admin.sock"
   processes:
     _enabled: "{{ inventory_hostname == 'instance' }}"
 

molecule/default/prepare.yml

@@ -2,7 +2,8 @@
 - name: Prepare
   hosts: all
   tasks:
-    - name: Update apt cache
+    - name: Update apt cache and install HAProxy
       ansible.builtin.apt:
         update_cache: true
         cache_valid_time: 600
+        name: haproxy

molecule/default/verify.yml

@@ -18,6 +18,15 @@
       register: result
       failed_when: result is changed
 
+    - name: Retrieve telegraf user groups
+      ansible.builtin.getent:
+        database: group
+        key: haproxy
+
+    - name: Check telegraf user is a member of the haproxy group
+      ansible.builtin.fail:
+      when: '"telegraf" not in ansible_facts.getent_group.haproxy'
+
     - name: Ensure Telegraf configuration files are correct
       ansible.builtin.copy:
         src: "{{ item | basename }}"

tasks/main.yml

@@ -68,9 +68,12 @@
     append: true
   # groups may not exist yet ¯\_(ツ)_/¯
   ignore_errors: true # noqa ignore-errors
-  when: item in _telegraf_inputs
+  when:
+    - item in _telegraf_inputs
+    - _telegraf_inputs[item]._enabled | d(True)
   loop:
     - docker
+    - haproxy
   notify: restart telegraf
   vars:
     _telegraf_inputs: >-

templates/telegraf-macros.j2

@@ -23,7 +23,7 @@
 {% macro telegraf_format_option(option, value) -%}
 {% if value is string %}
 {{ option }} = "{{ value }}"
-{% elif value is bool %}
+{% elif value is boolean %}
 {{ option }} = {{ value | string | lower }}
 {% elif value is list %}
 {%   if value %}

test_plugins/type_tests.py

@@ -1,13 +1,9 @@
-def test_bool(value):
-    return isinstance(value, bool)
-
 def test_list(value):
     return isinstance(value, list)
 
 class TestModule(object):
 
     def tests(self):
         return {
-            'bool': test_bool,
             'list': test_list
         }