Initial opensource release

Co-authored-by: George Melikov <mail@gmelikov.ru>
Co-authored-by: Dmitry Burmistrov <pyctrl.dev@gmail.com>
Co-authored-by: Eugene Frolov <eugene@frolov.net.ru>

Author: 4 people

.gitignore

@@ -0,0 +1,113 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# IDE
+.idea/
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+ChangeLog
+cover/
+
+# OS
+.DS_Store
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.tox
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+.pytest_cache/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+
+# Documentation
+docs/build
+docs/source/*.png
+
+*~

AUTHORS

@@ -0,0 +1,4 @@
+Alexandr Popov <popov2al@gmail.com>
+George Melikov <mail@gmelikov.ru>
+Dmitry Burmistrov <pyctrl.dev@gmail.com>
+Eugene Frolov <eugene@frolov.net.ru>

README.md

@@ -0,0 +1 @@
+Awesome metric sending library for nice guys!

obsender/__init__.py

@@ -0,0 +1,94 @@
+import contextlib
+import datetime
+import inspect
+import json
+import logging
+import numbers
+import uuid
+try:
+    from time import monotonic
+except ImportError:
+    from monotonic import monotonic
+
+import six
+
+from obsender import exceptions
+
+
+class DurationMixin(object):
+    """Mixin to meter timedelta and send its metric for wrapped code"""
+
+    @contextlib.contextmanager
+    def send_duration(self, metric_id, method_name='send_metric', **kwargs):
+        if not hasattr(self, method_name):
+            raise exceptions.SendMetricException(
+                'Method %s not found' % method_name
+            )
+        method = getattr(self, method_name)
+        start_time = monotonic()
+        try:
+            yield
+        finally:
+            method(
+                metric_id,
+                (monotonic() - start_time),
+                **kwargs
+            )
+
+
+class SenderLoggerAdapter(logging.LoggerAdapter):
+    """Writes Sender info for each log entry"""
+
+    def __init__(self, logger, sender):
+        super(SenderLoggerAdapter, self).__init__(logger, {})
+        self._sender = sender
+
+    def process(self, msg, kwargs):
+        _msg = ("[obsender_sender=%s host=%s, app_name=%s] %s"
+                % (self._sender.__class__.__name__,
+                   self._sender.host,
+                   self._sender.app_name,
+                   msg))
+        return _msg, kwargs
+
+
+def jsonify(obj):
+    if isinstance(obj, uuid.UUID):
+        return str(obj)
+    elif isinstance(obj, datetime.datetime) and obj.tzinfo is None:
+        # TODO(d.burmistrov): make TZ conversion
+        return obj.isoformat(sep='T') + 'Z'
+    elif isinstance(obj, datetime.timedelta):
+        return str(obj.total_seconds())
+    else:
+        raise TypeError(obj)
+
+
+def stringify(obj):
+    if isinstance(obj, six.string_types):
+        return obj
+    elif obj is None:
+        raise TypeError("can't convert ambiguous value %r" % obj)
+    elif isinstance(obj, bool):
+        return str(obj).lower()
+    elif isinstance(obj, numbers.Number):
+        return str(obj)
+    elif isinstance(obj, uuid.UUID):
+        return jsonify(obj)
+    elif isinstance(obj, (datetime.datetime, datetime.timedelta)):
+        return jsonify(obj)
+    elif isinstance(obj, (list, tuple, dict)):
+        return json.dumps(obj, default=jsonify)
+    elif inspect.isclass(obj):
+        return '%s.%s' % (obj.__module__, obj.__name__)
+    elif isinstance(obj, BaseException):
+        return repr(obj)
+    else:
+        raise TypeError("can't convert unsupported value %r" % obj)
+
+
+def floatify(obj):
+    if isinstance(obj, numbers.Number):
+        return float(obj)
+    else:
+        raise TypeError("Can't convert unsupported value %r" % obj)

obsender/common.py

@@ -0,0 +1,56 @@
+from oslo_config import cfg
+
+from obsender import constants
+
+# Config example
+#
+# [victoria_metrics]
+# enabled = False
+# host = "localhost"
+# port = 8125
+# global_tags = {}
+# prefix = "apps.application_name.dev"
+# obsender_host = "localhost"
+
+
+victoria_metrics_opts = [
+    cfg.BoolOpt('enabled',
+                default=False,
+                help="Enable sending of metrics to Victoria Metrics"),
+    cfg.StrOpt('host',
+               default=None,
+               help="Destination host to send metrics"),
+    cfg.StrOpt('prefix',
+               default='',
+               help=("Prefix of metrics. Should be "
+                     "'apps.<application_name>.<environment>'")),
+    cfg.IntOpt('port',
+               default=8125,
+               help="Destination port to send metrics"),
+    cfg.DictOpt('global_tags',
+                default=None,
+                help="Global tags for metrics in Victoria Metrics"),
+    cfg.StrOpt('obsender_host',
+               default=None,
+               help="Specifies host to send metrics for"),
+]
+
+# dpp_events_opts = [
+#     cfg.BoolOpt('enabled',
+#                 default=False,
+#                 help="Enable sending of data to DPP"),
+#     cfg.StrOpt('src_host',
+#                default=None,
+#                help="Determines host to send data for"),
+#     cfg.StrOpt('dpp_url',
+#                default='',
+#                help="Determines Data Platform endpoint for data push"),
+#     cfg.FloatOpt('timeout',
+#                  default=constants.DEFAULT_TIMEOUT,
+#                  help="Determines timeout for waiting data upload"),
+# ]
+
+
+CONF = cfg.CONF
+CONF.register_opts(victoria_metrics_opts, constants.VICTORIA_METRICS_DOMAIN)
+#CONF.register_opts(dpp_events_opts, constants.DPP_EVENTS_DOMAIN)

obsender/config.py

@@ -0,0 +1,8 @@
+# VictoriaMetrics config section name
+VICTORIA_METRICS_DOMAIN = 'victoria_metrics'
+
+# DPP for send events config section name
+DPP_EVENTS_DOMAIN = 'dpp_events'
+
+# Default timeout for send event
+DEFAULT_TIMEOUT = 3