summaryrefslogtreecommitdiffstats
path: root/extra/docker/elk/tools/DMaaPServiceMocker
diff options
context:
space:
mode:
Diffstat (limited to 'extra/docker/elk/tools/DMaaPServiceMocker')
-rwxr-xr-xextra/docker/elk/tools/DMaaPServiceMocker/ds_mocker.py257
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/event_abated.json27
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/event_onset.json26
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_active.json28
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_final_failed.json42
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_final_open.json28
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_final_success.json40
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_operation.json28
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_failure.json29
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_success.json29
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_disabled.json29
-rw-r--r--extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_missing.json18
12 files changed, 0 insertions, 581 deletions
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/ds_mocker.py b/extra/docker/elk/tools/DMaaPServiceMocker/ds_mocker.py
deleted file mode 100755
index bd6caecce..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/ds_mocker.py
+++ /dev/null
@@ -1,257 +0,0 @@
-#!/usr/bin/env python3
-import os
-import json
-import copy
-import random
-import requests
-import uuid
-import time
-from datetime import datetime
-
-def luck(n=2):
- """ gives 1 chance out of n (default: 2) to return True """
- assert n > 1
- return bool(random.randint(0, n-1))
-def now_dmaap_timestamp():
- return str(datetime.now().timestamp()).replace(".","")[:13]
-def now_notification_time():
- return datetime.now().strftime("%Y-%m-%d %H:%M:%S.%f+00:00")
-
-CONTROL_LOOP_NAMES = [
- 'CL-vCPE-d925ed73',
- 'CL-vCPE-37b1c91e',
- 'CL-vCPE-c2597657',
- 'CL-vCPE-a11318ba',
- 'CL-vCPE-5321c558',
-]
-
-TEMPLATES = {
- 'event_abated' :'event_abated.json',
- 'event_onset' :'event_onset.json',
- 'notification_active' :'notification_active.json',
- 'notification_final_failed' :'notification_final_failed.json',
- 'notification_final_open' :'notification_final_open.json',
- 'notification_final_success' :'notification_final_success.json',
- 'notification_operation_failure' :'notification_operation_failure.json',
- 'notification_operation' :'notification_operation.json',
- 'notification_operation_success' :'notification_operation_success.json',
- 'notification_rejected_disabled' :'notification_rejected_disabled.json',
- 'notification_rejected_missing' :'notification_rejected_missing.json',
-}
-
-ERROR_MESSAGES = [
- ('APPC', 'APPC1 : timeout on restart','RESTART'),
- ('APPC', 'APPC2 : cannot restart','RESTART'),
- ('SO', 'SO1 : scale up failed', 'SCALEUP'),
- ('SO', 'SO2 : scale down failed', 'SCALEDOWN'),
-]
-
-for key in TEMPLATES:
- with open(TEMPLATES[key]) as f:
- content = f.read()
- TEMPLATES[key] = json.loads(content)
-
-
-class DMaaPMessage(dict):
-
- dmaap_host_url = "http://dmaap.host.url:9200/"
- dmaap_username = None
- dmaap_password = None
-
- @classmethod
- def from_template(cls, tmpl, **kwargs):
- obj = cls()
- obj.update(copy.deepcopy(TEMPLATES[tmpl]))
- for keys,value in kwargs.items():
- current_node = obj
- keys = keys.split(".")
- key = keys[0]
- for i in range(len(keys) - 1):
- current_node = current_node[keys[i]]
- key = keys[i]
- current_node[key] = value
- return obj
-
- def publish(self, topic):
- url = "%s/events/%s" % (self.dmaap_host_url, topic)
- auth = None
- if self.dmaap_username and self.dmaap_password:
- auth = (self.dmaap_username, self.dmaap_password)
- response = requests.post(url, data=json.dumps(self), auth=auth)
- return response.status_code
-
-class Event(DMaaPMessage):
-
- topic = "DCAE-CL-EVENT"
-
- @staticmethod
- def abated(**kwargs):
- return Event.from_template('event_abated', **kwargs)
-
- @staticmethod
- def onset(**kwargs):
- return Event.from_template('event_onset', **kwargs)
-
- def publish(self):
- return super().publish(self.topic)
-
-
-class Notification(DMaaPMessage):
-
- topic = "POLICY-CL-MGT"
-
- @classmethod
- def from_template(cls, tmpl, **kwargs):
- kwargs['notificationTime'] = now_notification_time()
- return super().from_template(tmpl, **kwargs)
-
- @staticmethod
- def active(**kwargs):
- return Notification.from_template('notification_active', **kwargs)
-
- @staticmethod
- def final(**kwargs):
- class FinalNotification(Notification):
- @staticmethod
- def success(**kwargs):
- return FinalNotification.from_template('notification_final_success', **kwargs)
- @staticmethod
- def failed(**kwargs):
- msg = FinalNotification.from_template('notification_final_failed', **kwargs)
- error = ERROR_MESSAGES[random.randint(0, len(ERROR_MESSAGES) - 1)]
- h = msg['history'][-1]
- h['actor'],h['message'],h['operation'] = error[0],error[1],error[2]
- return msg
- @staticmethod
- def open(**kwargs):
- return FinalNotification.from_template('notification_final_open', **kwargs)
- return FinalNotification
-
- @staticmethod
- def operation(**kwargs):
- class OperationNotification(Notification):
- @staticmethod
- def success(**kwargs):
- return OperationNotification.from_template('notification_operation_success', **kwargs)
- @staticmethod
- def failure(**kwargs):
- return OperationNotification.from_template('notification_operation_failure', **kwargs)
- return OperationNotification.from_template('notification_operation', **kwargs)
-
- @staticmethod
- def rejected(**kwargs):
- class RejectedNotification(Notification):
- @staticmethod
- def disabled(**kwargs):
- return RejectedNotification.from_template('notification_rejected_disabled', **kwargs)
- @staticmethod
- def missing_fields(**kwargs):
- return RejectedNotification.from_template('notification_rejected_missing', **kwargs)
-
- return RejectedNotification
-
- def publish(self):
- return super().publish(self.topic)
-
-
-
-class CLStatus(object):
-
- def __init__(self, dmaap_url=None,
- missing=None, disabled=None, op_failure=None):
- self._stopped = False
- def maybe(thing, ):
- if thing is None:
- thing = not luck(10)
- return thing
- self._missing = maybe(missing)
- self._disabled = maybe(disabled)
- self._op_failure = maybe(op_failure)
- self._config = dict(
- requestID=str(uuid.uuid4()),
- closedLoopControlName=CONTROL_LOOP_NAMES[random.randint(0, len(CONTROL_LOOP_NAMES) - 1)]
- )
-
- def __iter__(self):
- return next(self)
-
- def __next__(self):
- if self._stopped:
- raise StopIteration()
- config = self._config
- config.update(dict(closedLoopAlarmStart=now_dmaap_timestamp()))
- yield Event.onset(**config)
- if self._missing:
- self._stopped = True
- yield Notification.rejected().missing_fields(**config)
- raise StopIteration()
- elif self._disabled:
- self._stopped = True
- yield Notification.rejected().disabled(**config)
- raise StopIteration()
-
- yield Notification.active(**config)
- yield Notification.operation(**config)
-
- config['closedLoopAlarmEnd'] = now_dmaap_timestamp()
- if self._op_failure:
- yield Notification.operation().failure(**config)
- self._stopped = True
- yield Notification.final().failed(**config)
- else:
- yield Notification.operation().success(**config)
- yield Event.abated(**config)
- self._stopped = True
- yield Notification.final().success(**config)
- raise StopIteration()
-
-def print_usage():
- print("""
- ./ds_mocker.py <DMAAP_URL> <EVENT_TOPIC> [NOTIFICATION_TOPIC [REQUEST_TOPIC]]
- """)
- exit()
-
-def push(test_datas):
- for current_i, status in enumerate(test_datas):
- time.sleep(random.randint(0,3))
- for s in status:
- # print(s)
- status_code = s.publish()
- if status_code != 200:
- print("Error when publishing : status_code={}".format(status_code))
- exit(1)
- time.sleep(random.randint(0,3))
- print("%03d,missing:%5s,disabled:%5s,op_failure:%5s - %s" % (current_i, status._missing, status._disabled, status._op_failure, status._config))
-
-
-
-def generate_dataset_1():
- test_datas = [CLStatus(missing=False, disabled=False, op_failure=False) for i in range(300)] \
- + [CLStatus(missing=True, disabled=False, op_failure=False) for i in range(5)] \
- + [CLStatus(missing=False, disabled=True, op_failure=False) for i in range(6)] \
- + [CLStatus(missing=False, disabled=False, op_failure=True) for i in range(12)]
- random.shuffle(test_datas)
- return test_datas
-
-def generate_error_dataset_1():
- test_datas = [CLStatus(missing=False, disabled=False, op_failure=True) for i in range(60)]
- random.shuffle(test_datas)
- return test_datas
-
-
-DATASETS = {
- 'dataset_1': generate_dataset_1,
- 'op_failure_1': generate_error_dataset_1,
-}
-
-if __name__ == "__main__":
- import sys
- if len(sys.argv) < 3:
- print_usage()
-
- DMaaPMessage.dmaap_host_url = sys.argv[1]
- Event.topic = sys.argv[2]
- Notification.topic = len(sys.argv) > 3 and sys.argv[3] or sys.argv[2]
- # Request.topic = len(sys.argv) > 4 or Notification.topic
- #push(DATASETS['op_failure_1']())
- push(DATASETS['dataset_1']())
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/event_abated.json b/extra/docker/elk/tools/DMaaPServiceMocker/event_abated.json
deleted file mode 100644
index ae0d4b7d0..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/event_abated.json
+++ /dev/null
@@ -1,27 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "closedLoopAlarmEnd": 1478710227625,
- "closedLoopAlarmStart": 1478709727496,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "closedLoopEventStatus": "ABATED",
- "from": "DCAE",
- "policyName": "vFirewall",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/event_onset.json b/extra/docker/elk/tools/DMaaPServiceMocker/event_onset.json
deleted file mode 100644
index 223f09659..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/event_onset.json
+++ /dev/null
@@ -1,26 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "closedLoopAlarmStart": 1478709385444,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "closedLoopEventStatus": "ONSET",
- "from": "DCAE",
- "policyName": "vFirewall",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "88e951ad-a07c-4748-9cef-34f32851a527",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_active.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_active.json
deleted file mode 100644
index 341a249de..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_active.json
+++ /dev/null
@@ -1,28 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "notification": "ACTIVE",
- "notificationTime": "2016-11-09 16:46:29.721000+00:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_failed.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_failed.json
deleted file mode 100644
index 4891c7eec..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_failed.json
+++ /dev/null
@@ -1,42 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmEnd": 1478710489739,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "history": [
- {
- "actor": "APPC",
- "end": 1478637014434,
- "message": "<APPC ERROR code/description>",
- "operation": "RESTART",
- "outcome": "FAILED",
- "start": 1478637014430,
- "subRequestId": "1",
- "target": "vserver.vserver-name"
- }
- ],
- "message": "actor=APPC,operation=RESTART,target=vserver.vserver-name,subRequestId=1,outcome=FAILED",
- "notification": "FINAL: FAILURE",
- "notificationTime": "2016-11-08 15:30:14.434000-05:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_open.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_open.json
deleted file mode 100644
index da9e6e11c..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_open.json
+++ /dev/null
@@ -1,28 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "closedLoopAlarmEnd": 1478710489739,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "notification": "FINAL: OPEN",
- "notificationTime": "2016-11-08 15:30:14.434000-05:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_success.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_success.json
deleted file mode 100644
index 3d027eb8b..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_final_success.json
+++ /dev/null
@@ -1,40 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmEnd": 1478710489739,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "history": [
- {
- "actor": "APPC",
- "end": 1478709989738,
- "operation": "RESTART",
- "start": 1478709989734,
- "subRequestId": "1",
- "target": "vserver.vserver-name"
- }
- ],
- "message": "actor=APPC,operation=RESTART,target=vserver.vserver-name,subRequestId=1",
- "notification": "FINAL: SUCCESS",
- "notificationTime": "2016-11-09 11:46:29.738000-05:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation.json
deleted file mode 100644
index 341a249de..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation.json
+++ /dev/null
@@ -1,28 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "notification": "ACTIVE",
- "notificationTime": "2016-11-09 16:46:29.721000+00:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_failure.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_failure.json
deleted file mode 100644
index 5dbe33ca3..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_failure.json
+++ /dev/null
@@ -1,29 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "message": "<APPC ERROR code and/or message>",
- "notification": "OPERATION: FAILURE",
- "notificationTime": "2016-11-08 15:30:14.434000-05:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_success.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_success.json
deleted file mode 100644
index 9e18b979c..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_operation_success.json
+++ /dev/null
@@ -1,29 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "false",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "message": "actor=APPC,operation=RESTART,target=vserver.vserver-name,subRequestId=1",
- "notification": "OPERATION: SUCCESS",
- "notificationTime": "2016-11-09 11:46:29.738000-05:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_disabled.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_disabled.json
deleted file mode 100644
index 3d949870b..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_disabled.json
+++ /dev/null
@@ -1,29 +0,0 @@
-{
- "AAI": {
- "cloud-region.identity-url": "http://1.2.3.4:5000/v2.0",
- "complex.physical-location-id": "SNYSCA12",
- "generic-vnf.service-id": "eb477a13-f380-401e-b2bd-f2d444c63e54",
- "generic-vnf.vnf-name": "gupi1337p",
- "tenant.tenant-id": "8f7b9a8a-8607-4a01-a5ef-0b26f569dcbb",
- "vserver.is-closed-loop-disabled": "true",
- "vserver.prov-status": "PROV",
- "vserver.vserver-selflink": "https//2.3.4.5:1234/d5a992de-8a70-4d7d-b382-2bc6eea52317",
- "vserver.vserver-id": "08f6c1f9-99e7-49f3-a662-c62b9f200d79",
- "vserver.vserver-name": "gupi1337pm004"
- },
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "message": "Closed Loop Disabled",
- "notification": "REJECTED",
- "notificationTime": "2016-05-11 15:09:23.896000+00:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}
diff --git a/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_missing.json b/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_missing.json
deleted file mode 100644
index c901401a9..000000000
--- a/extra/docker/elk/tools/DMaaPServiceMocker/notification_rejected_missing.json
+++ /dev/null
@@ -1,18 +0,0 @@
-{
- "AAI": {},
- "OPS_CL_timer": 600,
- "closedLoopAlarmStart": 1478709989621,
- "closedLoopControlName": "ClosedLoop-3ffd062d-7589-43b2-865a-139b64e2d402",
- "closedLoopEventClient": "DCAE_INSTANCE_ID.dcae-tca",
- "from": "Policy",
- "message": "Missing AAI tag",
- "notification": "REJECTED",
- "notificationTime": "2016-05-11 14:42:23.629000+00:00",
- "policyName": "ClosedLoop.vUSP",
- "policyScope": "resource=SampleResource,service=SampleService,type=SampleType,closedLoopControlName=SampleClosedLoop",
- "policyVersion": "v0.0.1",
- "requestID": "f889f60c-a715-48c0-801e-26428f6176b9",
- "target": "vserver.vserver-name",
- "target_type": "VM",
- "version": "1.0.2"
-}