Merge ~axino/charm-telegraf/+git/telegraf-charm:sentry_relation into ~telegraf-charmers/charm-telegraf:master

[Junien F]

add sentry relation

[🤖 Canonical IS Merge Bot (canonical-is-mergebot)]

This merge proposal is being monitored by mergebot. Change the status to Approved to merge.

[🤖 Canonical IS Merge Bot (canonical-is-mergebot)]

Change successfully merged at revision 20517fdf52cfd62d9067de3e398eb89af0862904

diff --git a/hooks/relations/sentry-metrics/requires.py b/hooks/relations/sentry-metrics/requires.py
 new file mode 100644
index 0000000..4a3524f
--- /dev/null
+++ b/hooks/relations/sentry-metrics/requires.py
@@ -0,0 +1,5 @@
+from charms import reactive
+
+
+class SentryEndpoint(reactive.Endpoint):
+    pass
diff --git a/metadata.yaml b/metadata.yaml
index 912f6f5..bf43b34 100644
--- a/metadata.yaml
+++ b/metadata.yaml
@@ -69,6 +69,9 @@ requires:
   redis:
     interface: redis
     scope: container
+  sentry:
+    interface: sentry-metrics
+    scope: container
 provides:
   prometheus-client:
     interface: http
diff --git a/reactive/telegraf.py b/reactive/telegraf.py
index b2732f1..964f497 100644
--- a/reactive/telegraf.py
+++ b/reactive/telegraf.py
@@ -619,6 +619,34 @@ def redis_input(redis):
     set_state('telegraf.needs_reload')
 
 
+@when('endpoint.sentry.joined')
+def sentry_input(sentry):
+    template = """
+[[inputs.statsd]]
+  protocol = "udp"
+  service_address = ":8125"
+  delete_gauges = false
+  delete_counters = false
+  delete_sets = false
+  delete_timings = false
+"""
+    config_path = '{}/{}.conf'.format(get_configs_dir(), 'sentry')
+
+    rels = hookenv.relations_of_type('sentry')
+    if rels:
+        for rel in rels:
+            input_config = render_template(template, {}) + \
+                render_extra_options("inputs", "sentry")
+            hookenv.log("Updating {} plugin config file".format('sentry'))
+            host.write_file(config_path, input_config.encode('utf-8'))
+            set_state('plugins.sentry.configured')
+    elif os.path.exists(config_path):
+        os.unlink(config_path)
+        remove_state('plugins.sentry.configured')
+
+    set_state('telegraf.needs_reload')
+
+
 @when('exec.available')
 def exec_input(exec_rel):
     template = """