Commit Graph

16 Commits

Author SHA1 Message Date
Witek Bedyk d47bbae4e8 Use Confluent Kafka client
The change introduces the possibility to run the persister with the new
confluent-kafka client. It has to be enabled in the configuration file.

Story: 2003705
Task: 35858

Depends-On: https://review.opendev.org/675297
Change-Id: I8d9e173e9a252712fb285c0676c26334e1f677a7
2019-09-19 15:09:23 +02:00
zhangjianweibj 3db7b179ef Fix python3 json loads error
`oslo_serialization.jsonutils.loads` is a more appropriate solution
Task: 36071
Story: 2006285

Change-Id: I8e2775a283b4670a8979541602a3f245c18e5d35
2019-08-03 08:57:14 +08:00
Dobroslaw Zybort c8b9b81f61 Py3: Fix encoding of message in RetryEngine
Change-Id: I07b96fb8ed486d620f9911827a1f3182fe0e9b84
2018-09-12 11:45:59 +00:00
Tomasz Trębski e1a9b9a96a Integrate with oslo.conf and oslo.log
Change upgrades the monasca-notification to leverage
the capabilities of both oslo.log and oslo.conf:

- configuration of logging separated from application settings
- ability to enforce data types for application settings
- ability to use oslo.config-generator capabilities
- automatic configuration parsing done by oslo.cfg

That change will bring it closer to the rest of monasca
components where such transition has happened already.
However, in the rest of monasca, oslo.cfg was partially
or fully implemented whereas monasca-notification has
been relying on YAML based configuration file.

Therefore backward compatybility for such format will
be kept for now.

Story: 2000959
Task: 4093
Task: 4092

Change-Id: Ia75c3b60d0fada854178f21ca5ccb9e6a880f37f
2017-10-20 09:32:11 +02:00
Artur Basiak 68fac3b664 Use absolute paths for imports
Absolute paths are required for importing modules.
Python3 cannot find modules if absolute paths are not used.

Change-Id: Id060f269bfb1d17ccad844451678359e664386fa
2017-07-18 11:11:53 +00:00
Artur Basiak 722ecaa7a5 Add config option for statsd
Add new section to config file with configuration for statsd
host and port. Add modification in notification engines.
According to the monasca-agent change:
https://review.openstack.org/#/c/381417

Change-Id: I6e99bae5e50f3670ae8b4a0c7ac5af3c747bcd68
2016-12-02 07:10:52 +01:00
Cao Xuan Hoang 69f4c2b8e3 Clean imports in code
This patch set modifies lines which are importing objects
instead of modules. As per openstack import guide lines, user should
import modules in a file not objects.

http://docs.openstack.org/developer/hacking/#imports

Change-Id: I3c5c7368fb006f3691d07cef9557c20a42cc5b76
2016-10-06 15:27:06 +07:00
Michael James Hoppal 063c4f1d1d Query database to see if the periodic notificiation changes
Also added notification id to notification object we construct in the
alarm processor

Change-Id: I6ccfffc9102bec8f670df13268e244cb0c998950
2016-08-29 15:11:20 -06:00
haali1 be6fb21e19 Add HipChat and Slack Notification types
This patch
   1. Supports for loading new notification types as plugins.
   2) Adds new plugins for HipChat and Slack
   3) Insert Notification types during startup

Partially-implements: blueprint notification-engine-plugin
Change-Id: I246ced3fe22a9797a3c8384f7bda166797cfac3a
2016-07-29 07:59:32 -07:00
Michael James Hoppal 79189ca811 Adding support for periodic notifications
New periodic notification engine that will take a notification send it, and then
place it back onto the periodic notification topic. Once the alarm associated
with the notification has transitioned to a state that is different from the
original state the notification is removed from the queue.

Change-Id: Ie3103a0ec30abcd8dfc53869b1c3135953aabf3a
2016-05-09 08:18:11 -06:00
Joe Keen 20b56528ef Retry engine trys to write bad data to Kafka
Previous retry fix did not actually fix the problem.

Change-Id: I2aa728d86a9cd21022d681149fae8aeebf08be24
2016-04-06 16:01:18 -06:00
Joe Keen 6e2961c8dc Retry engine trys to write bad data to Kafka
The retry engine did not convert a notification object into json before
attempting to send it to Kafka and the Kafka publisher raised an exception.
This causes the notification system to restart before committing that offset to
Kafka.  At that point the notification system is stuck because there's no way
to move past the notification that's causing the restart.

Change-Id: I473a0fa14f28b945702d879f5b17c5807f89e887
Closes-Bug:#1566057
2016-04-04 17:34:07 -06:00
Michael James Hoppal 8f05261e6a Add in HP Copyrights
Change-Id: I54d8bb19e6cd44557cf4757bb1283c8b9821ba35
2016-01-27 12:56:23 -07:00
Joe Keen 6b5d79df5f Migrate notification engine to common kafka interface
Change-Id: I6963e71edfe1b694e5299f400b6cdc07e6dd4354
2015-11-02 14:31:10 -07:00
Ryan Brandt ef0d82fbbc Changes to log messages to support unicode
Change-Id: Iefb3b4d577d8c4dc4d2b1ace5c155d2dc3d5ef9c
2015-05-05 16:54:32 -06:00
Joe Keen 9f0e65028f Added retry engine to notification system
Change-Id: Iea1a05c1b7336b9e3e8aeb972e0f9ba1b7f74d69
2015-02-09 11:40:02 -07:00