projects / osm / MON.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: f606443) | patch
Updated Kafka producer. This producer has the following changes: 29/2129/3
authorprithiv <prithiv.mohan@intel.com>
Wed, 6 Sep 2017 14:24:29 +0000 (15:24 +0100)
committerprithiv <prithiv.mohan@intel.com>
Thu, 7 Sep 2017 10:50:39 +0000 (12:50 +0200)
commit1a61c00aae49108b9c8e94caa812aa9800fbf870
treef898ccee190056703bfb93913ac858b4ac981a73tree | snapshot
parentf6064437ba352d7fee6b4a7a4e7cb2582ef5cd32commit | diff
Updated Kafka producer. This producer has the following changes:

 - Separated the schemas to models.
 - Updated message bus schemas.
 - Common producer for SO, monitoring tool plugins.

Signed-off-by: prithiv <prithiv.mohan@intel.com>
24 files changed:
core/message-bus/northbound_consumer.py [deleted file] blob | history
core/message-bus/northbound_producer.py [deleted file] blob | history
core/message_bus/northbound_consumer.py [new file with mode: 0644] blob
core/message_bus/producer.py [new file with mode: 0644] blob
core/models/acknowledge_alarm.json [new file with mode: 0644] blob
core/models/create_alarm.json [new file with mode: 0644] blob
core/models/create_alarm_resp.json [new file with mode: 0644] blob
core/models/create_metric_req.json [new file with mode: 0644] blob
core/models/create_metric_resp.json [new file with mode: 0644] blob
core/models/delete_alarm_req.json [new file with mode: 0644] blob
core/models/delete_alarm_resp.json [new file with mode: 0644] blob
core/models/delete_metric_req.json [new file with mode: 0644] blob
core/models/delete_metric_resp.json [new file with mode: 0644] blob
core/models/list_alarm_req.json [new file with mode: 0644] blob
core/models/list_alarm_resp.json [new file with mode: 0644] blob
core/models/list_metric_req.json [new file with mode: 0644] blob
core/models/list_metric_resp.json [new file with mode: 0644] blob
core/models/notify_alarm.json [new file with mode: 0644] blob
core/models/read_metric_data_req.json [new file with mode: 0644] blob
core/models/read_metric_data_resp.json [new file with mode: 0644] blob
core/models/update_alarm_req.json [new file with mode: 0644] blob
core/models/update_alarm_resp.json [new file with mode: 0644] blob
core/models/update_metric_req.json [new file with mode: 0644] blob
core/models/update_metric_resp.json [new file with mode: 0644] blob