dcaegen2 vescollector seedcode

Initial seed code delivery for vescollector for support
on the gen2dcae platform

Issue-ID: DCAEGEN2-52
Change-Id: Id2477eb266f05caf64c67dd809b1ad146ff4fb92
Signed-off-by: VENKATESH KUMAR <vv770d@att.com>

3 files changed, 460 insertions, 0 deletions

diff --git a/dpo/tosca_model/schema.yaml b/dpo/tosca_model/schema.yaml
new file mode 100644
index 00000000..f2eaae76
--- /dev/null
+++ b/dpo/tosca_model/schema.yaml
@@ -0,0 +1,240 @@
+tosca_definitions_version: tosca_simple_yaml_1_0_0
+capability_types:
+  dcae.capabilities.cdapHost:
+    derived_from: tosca.capabilities.Root
+  dcae.capabilities.composition.host:
+    derived_from: tosca.capabilities.Root
+    properties:
+      location_id:
+        type: string
+      service_id:
+        type: string
+  dcae.capabilities.dockerHost:
+    derived_from: tosca.capabilities.Root
+  dcae.capabilities.service.provide:
+    derived_from: tosca.capabilities.Root
+    properties:
+      request_format:
+        type: string
+      request_version:
+        type: string
+      response_format:
+        type: string
+      response_version:
+        type: string
+  dcae.capabilities.stream.subscribe:
+    derived_from: tosca.capabilities.Root
+    properties:
+      format:
+        type: string
+      version:
+        type: string
+relationship_types:
+  dcae.relationships.rework_connected_to:
+    derived_from: tosca.relationships.Root
+  dcae.relationships.rework_contained_in:
+    derived_from: tosca.relationships.Root
+node_types:
+  cloudify.dcae.nodes.Root:
+    derived_from: tosca.nodes.Root
+  cloudify.dcae.nodes.rework.DockerContainer:
+    attributes:
+      service_component_name:
+        type: string
+    capabilities:
+      service:
+        type: dcae.capabilities.service.provide
+      stream:
+        type: dcae.capabilities.stream.subscribe
+    derived_from: cloudify.dcae.nodes.Root
+    properties:
+      application_config:
+        required: true
+        type: map
+      image:
+        required: true
+        type: string
+      location_id:
+        required: true
+        type: string
+      service_component_type:
+        required: true
+        type: string
+      service_id:
+        required: true
+        type: string
+    requirements:
+    - host:
+        capability: dcae.capabilities.dockerHost
+        relationship: dcae.relationships.rework_contained_in
+    - stream:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
+  dcae.nodes.MicroService.cdap:
+    attributes:
+      service_component_name:
+        type: string
+    capabilities:
+      service:
+        type: dcae.capabilities.service.provide
+      stream:
+        type: dcae.capabilities.stream.subscribe
+    derived_from: cloudify.dcae.nodes.Root
+    properties:
+      app_config:
+        required: false
+        type: map
+      app_preferences:
+        required: false
+        type: map
+      artifact_name:
+        required: false
+        type: string
+      artifact_version:
+        required: false
+        type: string
+      jar_url:
+        type: string
+      location_id:
+        type: string
+      namespace:
+        required: false
+        type: string
+      program_preferences:
+        required: false
+        type: list
+      programs:
+        required: false
+        type: list
+      service_component_type:
+        type: string
+      service_endpoints:
+        required: false
+        type: list
+      service_id:
+        type: string
+      streamname:
+        required: false
+        type: string
+    requirements:
+    - host:
+        capability: dcae.capabilities.cdapHost
+        relationship: dcae.relationships.rework_contained_in
+    - stream:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
+  dcae.nodes.Root:
+    derived_from: tosca.nodes.Root
+  dcae.nodes.cdapApp:
+    attributes:
+      service_component_name:
+        type: string
+    derived_from: dcae.nodes.Root
+    properties:
+      jar_url:
+        required: true
+        type: string
+      location_id:
+        required: true
+        type: string
+      service_component_type:
+        required: true
+        type: string
+      service_id:
+        required: true
+        type: string
+    requirements:
+    - host:
+        capability: dcae.capabilities.cdapHost
+        relationship: dcae.relationships.rework_contained_in
+    - composition:
+        capability: dcae.capabilities.composition.host
+  dcae.nodes.dockerApp:
+    attributes:
+      service_component_name:
+        type: string
+    derived_from: dcae.nodes.Root
+    properties:
+      image:
+        required: true
+        type: string
+      location_id:
+        required: true
+        type: string
+      service_component_type:
+        required: true
+        type: string
+      service_id:
+        required: true
+        type: string
+    requirements:
+    - host:
+        capability: dcae.capabilities.dockerHost
+        relationship: dcae.relationships.rework_contained_in
+    - composition:
+        capability: dcae.capabilities.composition.host
+  dcae.nodes.dockerApp.ves:
+    derived_from: dcae.nodes.dockerApp
+    properties:
+      docker_collector.dmaap.streamid:
+        type: string
+      docker_collector.inputQueue.maxPending:
+        type: string
+      docker_collector.keystore.alias:
+        type: string
+      docker_collector.keystore.file.location:
+        type: string
+      docker_collector.keystore.passwordfile:
+        type: string
+      docker_collector.schema.checkflag:
+        type: string
+      docker_collector.schema.file:
+        type: string
+      docker_collector.service.port:
+        type: string
+      docker_collector.service.secure.port:
+        type: string
+      docker_header.authflag:
+        type: string
+      docker_header.authlist:
+        type: string
+      docker_tomcat.maxthreads:
+        type: string
+      service_0_service_endpoint:
+        type: string
+      service_0_service_name:
+        type: string
+      service_0_verb:
+        type: string
+      stream_0_key:
+        type: string
+      stream_0_route:
+        type: string
+      stream_1_key:
+        type: string
+      stream_1_route:
+        type: string
+      stream_2_key:
+        type: string
+      stream_3_key:
+        type: string
+    capabilities:
+      service_0:
+        type: dcae.capabilities.service.provide
+      stream_0:
+        type: dcae.capabilities.stream.subscribe
+      stream_1:
+        type: dcae.capabilities.stream.subscribe
+    requirements:
+    - stream_0:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
+    - stream_1:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
+    - stream_2:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
+    - stream_3:
+        capability: dcae.capabilities.stream.subscribe
+        relationship: dcae.relationships.rework_connected_to
diff --git a/dpo/tosca_model/template.yaml b/dpo/tosca_model/template.yaml
new file mode 100644
index 00000000..9f2379ea
--- /dev/null
+++ b/dpo/tosca_model/template.yaml
@@ -0,0 +1,101 @@
+tosca_definitions_version: tosca_simple_yaml_1_0_0
+metadata:
+  template_name: ves
+imports:
+- schema: schema.yaml
+topology_template:
+  node_templates:
+    ves:
+      type: dcae.nodes.dockerApp.ves
+      properties:
+        docker_collector.dmaap.streamid: fault=sec_fault,roadm-sec-to-hp|syslog=sec_syslog|heartbeat=sec_heartbeat|measurementsForVfScaling=sec_measurement|mobileFlow=sec_mobileflow|other=sec_other|stateChange=sec_statechange|thresholdCrossingAlert=sec_thresholdCrossingAlert
+        docker_collector.inputQueue.maxPending: '8096'
+        docker_collector.keystore.alias: dynamically generated
+        docker_collector.keystore.file.location: /opt/app/dcae-certificate/keystore.jks
+        docker_collector.keystore.passwordfile: /opt/app/dcae-certificate/.password
+        docker_collector.schema.checkflag: '1'
+        docker_collector.schema.file: ./etc/CommonEventFormat_27.2.json
+        docker_collector.service.port: '8080'
+        docker_collector.service.secure.port: '-1'
+        docker_header.authflag: '0'
+        docker_header.authlist: userid1,base64encodepwd1|userid2,base64encodepwd2
+        docker_tomcat.maxthreads: '200'
+        location_id:
+          get_property:
+          - SELF
+          - composition
+          - location_id
+        service_0_service_endpoint: null
+        service_0_service_name: null
+        service_0_verb: POST
+        service_id:
+          get_property:
+          - SELF
+          - composition
+          - service_id
+        stream_0_key: sec_measurement_unsecure
+        stream_0_route: eventListener/v1
+        stream_1_key: sec_measurement
+        stream_1_route: eventListener/v1/eventBatch
+        stream_2_key: sec_fault
+        stream_3_key: sec_fault_unsecure
+      capabilities:
+        service_0:
+          properties:
+            request_format: VES_specification
+            request_version: 4.27.2
+            response_format: ves.coll.response
+            response_version: 1.0.0
+        stream_0:
+          properties:
+            format: VES_specification
+            version: 4.27.2
+        stream_1:
+          properties:
+            format: VES_specification
+            version: 4.27.2
+      requirements:
+      - stream_0:
+          capability: dcae.capabilities.stream.subscribe
+          relationship: dcae.relationships.rework_connected_to
+          node_filter:
+            capabilities:
+            - dcae.capabilities.stream.subscribe:
+                properties:
+                - format:
+                  - equal: VES_specification
+                - version:
+                  - equal: 4.27.2
+      - stream_1:
+          capability: dcae.capabilities.stream.subscribe
+          relationship: dcae.relationships.rework_connected_to
+          node_filter:
+            capabilities:
+            - dcae.capabilities.stream.subscribe:
+                properties:
+                - format:
+                  - equal: VES_specification
+                - version:
+                  - equal: 4.27.2
+      - stream_2:
+          capability: dcae.capabilities.stream.subscribe
+          relationship: dcae.relationships.rework_connected_to
+          node_filter:
+            capabilities:
+            - dcae.capabilities.stream.subscribe:
+                properties:
+                - format:
+                  - equal: VES_specification
+                - version:
+                  - equal: 4.27.2
+      - stream_3:
+          capability: dcae.capabilities.stream.subscribe
+          relationship: dcae.relationships.rework_connected_to
+          node_filter:
+            capabilities:
+            - dcae.capabilities.stream.subscribe:
+                properties:
+                - format:
+                  - equal: VES_specification
+                - version:
+                  - equal: 4.27.2
diff --git a/dpo/tosca_model/translate.yaml b/dpo/tosca_model/translate.yaml
new file mode 100644
index 00000000..f1607e76
--- /dev/null
+++ b/dpo/tosca_model/translate.yaml
@@ -0,0 +1,119 @@
+tosca_definitions_version: tosca_simple_yaml_1_0_0
+metadata:
+  template_name: ves_translate
+imports:
+- schema: schema.yaml
+topology_template:
+  inputs:
+    docker_collector.dmaap.streamid:
+      type: string
+    docker_collector.inputQueue.maxPending:
+      type: string
+    docker_collector.keystore.alias:
+      type: string
+    docker_collector.keystore.file.location:
+      type: string
+    docker_collector.keystore.passwordfile:
+      type: string
+    docker_collector.schema.checkflag:
+      type: string
+    docker_collector.schema.file:
+      type: string
+    docker_collector.service.port:
+      type: string
+    docker_collector.service.secure.port:
+      type: string
+    docker_header.authflag:
+      type: string
+    docker_header.authlist:
+      type: string
+    docker_tomcat.maxthreads:
+      type: string
+    image:
+      type: string
+    location_id:
+      type: string
+    service_0_service_endpoint:
+      type: string
+    service_0_service_name:
+      type: string
+    service_0_verb:
+      type: string
+    service_component_type:
+      type: string
+    service_id:
+      type: string
+    stream_0_key:
+      type: string
+    stream_0_route:
+      type: string
+    stream_1_key:
+      type: string
+    stream_1_route:
+      type: string
+    stream_2_key:
+      type: string
+    stream_3_key:
+      type: string
+  substitution_mappings:
+    node_type: dcae.nodes.dockerApp.ves
+    capabilities:
+      service_0:
+      - ves
+      - stream
+      stream_0:
+      - ves
+      - stream
+      stream_1:
+      - ves
+      - stream
+    requirements:
+      host:
+      - ves
+      - host
+      stream_0:
+      - ves
+      - stream
+      stream_1:
+      - ves
+      - stream
+      stream_2:
+      - ves
+      - stream
+      stream_3:
+      - ves
+      - stream
+  node_templates:
+    ves:
+      type: cloudify.dcae.nodes.rework.DockerContainer
+      properties:
+        application_config:
+          collector.dmaap.streamid:
+            get_input: docker_collector.dmaap.streamid
+          collector.inputQueue.maxPending:
+            get_input: docker_collector.inputQueue.maxPending
+          collector.keystore.alias:
+            get_input: docker_collector.keystore.alias
+          collector.keystore.file.location:
+            get_input: docker_collector.keystore.file.location
+          collector.keystore.passwordfile:
+            get_input: docker_collector.keystore.passwordfile
+          collector.schema.checkflag:
+            get_input: docker_collector.schema.checkflag
+          collector.schema.file:
+            get_input: docker_collector.schema.file
+          collector.service.port:
+            get_input: docker_collector.service.port
+          collector.service.secure.port:
+            get_input: docker_collector.service.secure.port
+          header.authflag:
+            get_input: docker_header.authflag
+          header.authlist:
+            get_input: docker_header.authlist
+          tomcat.maxthreads:
+            get_input: docker_tomcat.maxthreads
+        location_id:
+          get_input: location_id
+        service_component_type: cdap_app_ves
+        service_id:
+          get_input: service_id