summaryrefslogtreecommitdiffstats
path: root/cdap/demo_blueprints
diff options
context:
space:
mode:
authorTommy Carpenter <tommy@research.att.com>2017-08-18 14:16:44 -0400
committerTommy Carpenter <tommy@research.att.com>2017-08-18 14:19:20 -0400
commitc272a87b84189f3bf8b3c7287199b816affc9926 (patch)
treeb8d67976ed993633dbb6310df40481c59c641860 /cdap/demo_blueprints
parent2e71445141fcbe92e8e12ab24d065040d8de6d9c (diff)
[DCAEGEN2-74] Push up initial CDAP plugin
Change-Id: I2bad410e5c55a59950cabe8fc13066954c4f5c92 Signed-off-by: Tommy Carpenter <tommy@research.att.com>
Diffstat (limited to 'cdap/demo_blueprints')
-rw-r--r--cdap/demo_blueprints/cdap_hello_world.yaml40
-rwxr-xr-xcdap/demo_blueprints/cdap_hello_world_reconfigure.sh4
-rw-r--r--cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml148
-rw-r--r--cdap/demo_blueprints/cdap_hello_world_with_laika.yaml80
-rw-r--r--cdap/demo_blueprints/cdap_hello_world_with_mr.yaml134
5 files changed, 406 insertions, 0 deletions
diff --git a/cdap/demo_blueprints/cdap_hello_world.yaml b/cdap/demo_blueprints/cdap_hello_world.yaml
new file mode 100644
index 0000000..1b7ff90
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world.yaml
@@ -0,0 +1,40 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+ - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+
+inputs:
+ hello_world_jar_url:
+ type: string
+ connected_broker_dns_name:
+ type: string
+ default : "cdap_broker"
+
+node_templates:
+
+ hw_cdap_app:
+ type: dcae.nodes.MicroService.cdap
+ properties:
+ service_component_type:
+ 'hello_world'
+ jar_url: { get_input : hello_world_jar_url }
+ artifact_name: "HelloWorld"
+ artifact_version: "3.4.3"
+ namespace: "cloudifyhwtest"
+ programs:
+ [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+ streamname:
+ 'who'
+ service_endpoints:
+ [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+ interfaces:
+ cloudify.interfaces.lifecycle:
+ create:
+ inputs:
+ connected_broker_dns_name: { get_input: connected_broker_dns_name }
+
+outputs:
+ hw_cdap_app_name:
+ value:
+ {get_attribute:[hw_cdap_app, service_component_name]}
diff --git a/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh b/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh
new file mode 100755
index 0000000..c5df2f5
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_reconfigure.sh
@@ -0,0 +1,4 @@
+#!/bin/bash
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_config_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"foo":"bar"}}, "allow_kwargs_override": true}'
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_preferences_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"fooprefs":"barprefs"}}, "allow_kwargs_override": true}'
+cfy executions start -d cdap-hello-world -w execute_operation -p '{"operation" : "reconfiguration.app_smart_reconfigure", "node_ids" : ["hw_cdap_app"], "operation_kwargs" : {"new_config_template" : {"fooprefs":"SO SMARTTTTTT", "foo":"SO SMART AGAINNNNN"}}, "allow_kwargs_override": true}'
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml b/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml
new file mode 100644
index 0000000..ea02543
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_dmaap.yaml
@@ -0,0 +1,148 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+ - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/dmaap/1.1.0/dmaap.yaml
+
+inputs:
+ hello_world_jar_url:
+ type: string
+ connected_broker_dns_name:
+ type: string
+ default : "cdap_broker"
+
+ #aaf inputs
+ client_role:
+ type: string
+ topic00fqtn:
+ type: string
+ topic01fqtn:
+ type: string
+ aafu0:
+ type: string
+ default: "foo0"
+ aafp0:
+ type: string
+ default: "bar0"
+ aafu1:
+ type: string
+ default : "foo1"
+ aafp1:
+ type: string
+ default : "bar1"
+ aafu2:
+ type: string
+ default: "foo2"
+ aafp2:
+ type: string
+ default: "bar2"
+ aafu3:
+ type: string
+ default : "foo3"
+ aafp3:
+ type: string
+ default : "bar3"
+
+node_templates:
+ topic00:
+ type: dcae.nodes.ExistingTopic
+ properties:
+ fqtn: { get_input : topic00fqtn }
+ topic01:
+ type: dcae.nodes.ExistingTopic
+ properties:
+ fqtn: { get_input : topic01fqtn }
+ feed00:
+ type: dcae.nodes.Feed
+ properties:
+ feed_name: "FEEDME-12"
+ feed_description: "Tommy Test feed for CDAP Publishes"
+ feed_version: 6.6.6
+ aspr_classification: "unclassified"
+
+ hw_cdap_app:
+ type: dcae.nodes.MicroService.cdap
+ properties:
+ service_component_type: 'hello_world'
+ jar_url: { get_input : hello_world_jar_url }
+ artifact_name: "HelloWorld"
+ artifact_version: "3.4.3"
+ namespace: "cloudifyhwtest"
+ programs:
+ [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+ streamname:
+ 'who'
+ service_endpoints:
+ [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+
+ #special key for CDAP plugin
+ connections:
+ streams_publishes:
+ - name: topic00 #MR pub 1
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey0"
+ aaf_username: { get_input: aafu0 }
+ aaf_password: { get_input: aafp0 }
+ - name: topic01 #MR pub 2
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey1"
+ aaf_username: { get_input: aafu1 }
+ aaf_password: { get_input: aafp1 }
+ - name: feed00 #Feed pub 1
+ location: mtc5
+ type: data_router
+ config_key: "mydrconfigkey"
+ streams_subscribes:
+ - name: topic00 #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey2"
+ aaf_username: { get_input: aafu2 }
+ aaf_password: { get_input: aafp2 }
+ - name: topic01
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey3"
+ aaf_username: { get_input: aafu3 }
+ aaf_password: { get_input: aafp3 }
+
+ relationships:
+ - type: dcae.relationships.publish_events
+ target: topic00 #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+ - type: dcae.relationships.publish_events
+ target: topic01
+ - type: dcae.relationships.subscribe_to_events
+ target: topic00
+ - type: dcae.relationships.subscribe_to_events
+ target: topic01
+ - type: dcae.relationships.publish_files
+ target: feed00
+
+ interfaces:
+ cloudify.interfaces.lifecycle:
+ create:
+ inputs:
+ connected_broker_dns_name: { get_input: connected_broker_dns_name }
+
+outputs:
+ hw_cdap_app_name:
+ value: {get_attribute:[hw_cdap_app, service_component_name]}
+
+ topic00_data:
+ description: "Topic 00 data"
+ value: { get_attribute: [hw_cdap_app, topic00]}
+
+ topic01_data:
+ description: "Topic 01 data"
+ value: { get_attribute: [hw_cdap_app, topic01]}
+
+
+
+
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml b/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml
new file mode 100644
index 0000000..4587a47
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_laika.yaml
@@ -0,0 +1,80 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+ - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/docker/2.1.0/node-type.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/relationship/1.0.0/node-type.yaml
+
+inputs:
+ hello_world_jar_url:
+ type: string
+ laika_image:
+ type: string
+ connected_broker_dns_name:
+ type: string
+ default : "cdap_broker"
+
+node_templates:
+
+ hw_cdap_app:
+ type: dcae.nodes.MicroService.cdap
+ properties:
+ service_component_type:
+ 'hello_world'
+ jar_url: { get_input : hello_world_jar_url }
+ artifact_name: "HelloWorld"
+ artifact_version: "3.4.3"
+ namespace: "cloudifyhwtest"
+ programs:
+ [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+ streamname:
+ 'who'
+ service_endpoints:
+ [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+
+ connections:
+ services_calls:
+ - service_component_type: laika
+ config_key: "laika_handle"
+
+ relationships:
+ - type: dcae.relationships.component_connected_to
+ target: laika-one
+
+ interfaces:
+ cloudify.interfaces.lifecycle:
+ create:
+ inputs:
+ connected_broker_dns_name: { get_input: connected_broker_dns_name }
+
+ laika-one:
+ type: dcae.nodes.DockerContainerForComponents
+ properties:
+ service_component_type: 'laika'
+ service_id: 'this_is_dumb'
+ location_id: 'this_is_dumb'
+ image: { get_input : laika_image }
+ # Trying without health check
+ relationships:
+ - type: dcae.relationships.component_contained_in
+ target: docker_host
+ interfaces:
+ cloudify.interfaces.lifecycle:
+ stop:
+ inputs:
+ cleanup_image:
+ False
+
+ docker_host:
+ type: dcae.nodes.SelectedDockerHost
+ properties:
+ location_id: 'this is dumb'
+ docker_host_override: 'platform_dockerhost'
+
+outputs:
+ hw_cdap_app_name:
+ value: {get_attribute:[hw_cdap_app, service_component_name]}
+
+
+
diff --git a/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml b/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml
new file mode 100644
index 0000000..e1e0adb
--- /dev/null
+++ b/cdap/demo_blueprints/cdap_hello_world_with_mr.yaml
@@ -0,0 +1,134 @@
+tosca_definitions_version: cloudify_dsl_1_3
+
+imports:
+ - http://www.getcloudify.org/spec/cloudify/3.4/types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/cdap/14.0.2/cdap_types.yaml
+ - {{ ONAPTEMPLATE_RAWREPOURL_org_onap_dcaegen2 }}/type_files/dmaap/1.1.0/dmaap.yaml
+
+inputs:
+ hello_world_jar_url:
+ type: string
+ connected_broker_dns_name:
+ type: string
+ default : "cdap_broker"
+
+ #aaf inputs
+ client_role:
+ type: string
+ topic00fqtn:
+ type: string
+ topic01fqtn:
+ type: string
+ aafu0:
+ type: string
+ default: "foo0"
+ aafp0:
+ type: string
+ default: "bar0"
+ aafu1:
+ type: string
+ default : "foo1"
+ aafp1:
+ type: string
+ default : "bar1"
+ aafu2:
+ type: string
+ default: "foo2"
+ aafp2:
+ type: string
+ default: "bar2"
+ aafu3:
+ type: string
+ default : "foo3"
+ aafp3:
+ type: string
+ default : "bar3"
+
+node_templates:
+ topic00:
+ type: dcae.nodes.ExistingTopic
+ properties:
+ fqtn: { get_input : topic00fqtn }
+
+ topic01:
+ type: dcae.nodes.ExistingTopic
+ properties:
+ fqtn: { get_input : topic01fqtn }
+
+ hw_cdap_app:
+ type: dcae.nodes.MicroService.cdap
+ properties:
+ service_component_type:
+ 'hello_world'
+ jar_url: { get_input : hello_world_jar_url }
+ artifact_name: "HelloWorld"
+ artifact_version: "3.4.3"
+ namespace: "cloudifyhwtest"
+ programs:
+ [{"program_type" : "flows", "program_id" : "WhoFlow"}, {"program_type" : "services", "program_id" : "Greeting"}]
+ streamname:
+ 'who'
+ service_endpoints:
+ [{"service_name" : "Greeting", "service_endpoint" : "greet", "endpoint_method" : "GET"}]
+
+ #special key for CDAP plugin
+ connections:
+ streams_publishes:
+ - name: topic00 #MR pub 1
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey0"
+ aaf_username: { get_input: aafu0 }
+ aaf_password: { get_input: aafp0 }
+ - name: topic01 #MR pub 2
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey1"
+ aaf_username: { get_input: aafu1 }
+ aaf_password: { get_input: aafp1 }
+ streams_subscribes:
+ - name: topic00 #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey2"
+ aaf_username: { get_input: aafu2 }
+ aaf_password: { get_input: aafp2 }
+ - name: topic01
+ location: mtc5
+ client_role: { get_input: client_role }
+ type: message_router
+ config_key: "myconfigkey3"
+ aaf_username: { get_input: aafu3 }
+ aaf_password: { get_input: aafp3 }
+
+ relationships:
+ - type: dcae.relationships.publish_events
+ target: topic00 #MEANT FOR DEMO ONLY! Subscribing and publishing to same topic. Not real example.
+ - type: dcae.relationships.publish_events
+ target: topic01
+ - type: dcae.relationships.subscribe_to_events
+ target: topic00
+ - type: dcae.relationships.subscribe_to_events
+ target: topic01
+
+ interfaces:
+ cloudify.interfaces.lifecycle:
+ create:
+ inputs:
+ connected_broker_dns_name: { get_input: connected_broker_dns_name }
+
+outputs:
+ hw_cdap_app_name:
+ value: {get_attribute:[hw_cdap_app, service_component_name]}
+
+ topic00_data:
+ description: "Topic 00 data"
+ value: { get_attribute: [hw_cdap_app, topic00]}
+
+ topic01_data:
+ description: "Topic 01 data"
+ value: { get_attribute: [hw_cdap_app, topic01]}
+