http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/java/org/apache/brooklyn/demo/WideAreaCassandraCluster.java ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/java/org/apache/brooklyn/demo/WideAreaCassandraCluster.java b/examples/simple-nosql-cluster/src/main/java/org/apache/brooklyn/demo/WideAreaCassandraCluster.java new file mode 100644 index 0000000..a19f817 --- /dev/null +++ b/examples/simple-nosql-cluster/src/main/java/org/apache/brooklyn/demo/WideAreaCassandraCluster.java @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.brooklyn.demo; + +import java.util.Arrays; +import java.util.List; + +import brooklyn.catalog.Catalog; +import brooklyn.catalog.CatalogConfig; +import brooklyn.config.ConfigKey; +import brooklyn.entity.basic.AbstractApplication; +import brooklyn.entity.basic.ConfigKeys; +import brooklyn.entity.basic.Entities; +import brooklyn.entity.basic.StartableApplication; +import brooklyn.entity.nosql.cassandra.CassandraDatacenter; +import brooklyn.entity.nosql.cassandra.CassandraFabric; +import brooklyn.entity.nosql.cassandra.CassandraNode; +import brooklyn.entity.proxying.EntitySpec; +import brooklyn.launcher.BrooklynLauncher; +import brooklyn.policy.EnricherSpec; +import brooklyn.policy.PolicySpec; +import brooklyn.policy.ha.ServiceFailureDetector; +import brooklyn.policy.ha.ServiceReplacer; +import brooklyn.policy.ha.ServiceRestarter; +import brooklyn.util.CommandLineUtil; + +import com.google.common.collect.Lists; + +@Catalog(name="Wide Area Cassandra Cluster Application", description="Deploy a Cassandra cluster across multiple geographies.") +public class WideAreaCassandraCluster extends AbstractApplication { + + public static final String DEFAULT_LOCATION_SPEC = "aws-ec2:us-east-1,rackspace-cloudservers-uk"; + + @CatalogConfig(label="Initial Cluster Size (per location)", priority=2) + public static final ConfigKey<Integer> CASSANDRA_CLUSTER_SIZE = ConfigKeys.newConfigKey( + "cassandra.cluster.initialSize", "Initial size of the Cassandra clusterss", 2); + + + + @Override + public void initApp() { + addChild(EntitySpec.create(CassandraFabric.class) + .configure(CassandraDatacenter.CLUSTER_NAME, "Brooklyn") + .configure(CassandraDatacenter.INITIAL_SIZE, getConfig(CASSANDRA_CLUSTER_SIZE)) // per location + .configure(CassandraDatacenter.ENDPOINT_SNITCH_NAME, "brooklyn.entity.nosql.cassandra.customsnitch.MultiCloudSnitch") + .configure(CassandraNode.CUSTOM_SNITCH_JAR_URL, "classpath://brooklyn/entity/nosql/cassandra/cassandra-multicloud-snitch.jar") + .configure(CassandraFabric.MEMBER_SPEC, EntitySpec.create(CassandraDatacenter.class) + .configure(CassandraDatacenter.MEMBER_SPEC, EntitySpec.create(CassandraNode.class) + .enricher(EnricherSpec.create(ServiceFailureDetector.class)) + .policy(PolicySpec.create(ServiceRestarter.class) + .configure(ServiceRestarter.FAILURE_SENSOR_TO_MONITOR, ServiceFailureDetector.ENTITY_FAILED))) + .policy(PolicySpec.create(ServiceReplacer.class) + .configure(ServiceReplacer.FAILURE_SENSOR_TO_MONITOR, ServiceRestarter.ENTITY_RESTART_FAILED)))); + } + + public static void main(String[] argv) { + List<String> args = Lists.newArrayList(argv); + String port = CommandLineUtil.getCommandLineOption(args, "--port", "8081+"); + String locations = CommandLineUtil.getCommandLineOption(args, "--location", DEFAULT_LOCATION_SPEC); + + BrooklynLauncher launcher = BrooklynLauncher.newInstance() + .application(EntitySpec.create(StartableApplication.class, WideAreaCassandraCluster.class) + .displayName("Cassandra")) + .webconsolePort(port) + .locations(Arrays.asList(locations)) + .start(); + + Entities.dumpInfo(launcher.getApplications()); + } +}
http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/ha-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/ha-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/ha-cassandra-cluster.yaml deleted file mode 100644 index 4a9ebc7..0000000 --- a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/ha-cassandra-cluster.yaml +++ /dev/null @@ -1,45 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# -# A YAML version of the HighAvailabilityCassandraCluster application -# -name: HA Cassandra cluster -location: aws-ec2:us-east-1 - -services: -- type: brooklyn.entity.nosql.cassandra.CassandraDatacenter - name: Brooklyn - brooklyn.config: - initialSize: 6 - enableAvailabilityZones: true - # See https://github.com/brooklyncentral/brooklyn/issues/973 - availabilityZoneNames: - - us-east-1b - - us-east-1c - - us-east-1e - numAvailabilityZones: 3 - snitchName: GossipingPropertyFileSnitch - memberSpec: - $brooklyn:entitySpec: - type: brooklyn.entity.nosql.cassandra.CassandraNode - brookyn.policies: - - type: brooklyn.policy.ha.ServiceRestarter - brooklyn.enrichers: - - type: brooklyn.policy.ha.ServiceFailureDetector - brooklyn.policies: - - type: brooklyn.policy.ha.ServiceReplacer http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/simple-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/simple-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/simple-cassandra-cluster.yaml deleted file mode 100644 index ff7b48c..0000000 --- a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/simple-cassandra-cluster.yaml +++ /dev/null @@ -1,28 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# -# A YAML version of the SimpleCassandraCluster application -# -name: Simple Cassandra cluster -location: localhost - -services: -- type: brooklyn.entity.nosql.cassandra.CassandraDatacenter - name: Brooklyn - brooklyn.config: - initialSize: 1 http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/wide-area-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/wide-area-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/wide-area-cassandra-cluster.yaml deleted file mode 100644 index 3e44e39..0000000 --- a/examples/simple-nosql-cluster/src/main/resources/brooklyn/demo/wide-area-cassandra-cluster.yaml +++ /dev/null @@ -1,41 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you under the Apache License, Version 2.0 (the -# "License"); you may not use this file except in compliance -# with the License. You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, -# software distributed under the License is distributed on an -# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -# KIND, either express or implied. See the License for the -# specific language governing permissions and limitations -# under the License. -# -# A YAML version of the WideAreaCassandraCluster application -# -name: Wide Area Cassandra cluster -locations: -- aws-ec2:us-east-1 -- rackspace-cloudservers-uk - -services: -- type: brooklyn.entity.nosql.cassandra.CassandraFabric - name: Brooklyn - brooklyn.config: - initialSize: 2 - snitchName: brooklyn.entity.nosql.cassandra.customsnitch.MultiCloudSnitch - customSnitchJarUrl: classpath://brooklyn/entity/nosql/cassandra/cassandra-multicloud-snitch.jar - memberSpec: - $brooklyn:entitySpec: - type: brooklyn.entity.nosql.cassandra.CassandraNode - brookyn.policies: - - type: brooklyn.policy.ha.ServiceRestarter - brooklyn.enrichers: - - type: brooklyn.policy.ha.ServiceFailureDetector - brooklyn.policies: - - type: brooklyn.policy.ha.ServiceReplacer http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/ha-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/ha-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/ha-cassandra-cluster.yaml new file mode 100644 index 0000000..4a9ebc7 --- /dev/null +++ b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/ha-cassandra-cluster.yaml @@ -0,0 +1,45 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# A YAML version of the HighAvailabilityCassandraCluster application +# +name: HA Cassandra cluster +location: aws-ec2:us-east-1 + +services: +- type: brooklyn.entity.nosql.cassandra.CassandraDatacenter + name: Brooklyn + brooklyn.config: + initialSize: 6 + enableAvailabilityZones: true + # See https://github.com/brooklyncentral/brooklyn/issues/973 + availabilityZoneNames: + - us-east-1b + - us-east-1c + - us-east-1e + numAvailabilityZones: 3 + snitchName: GossipingPropertyFileSnitch + memberSpec: + $brooklyn:entitySpec: + type: brooklyn.entity.nosql.cassandra.CassandraNode + brookyn.policies: + - type: brooklyn.policy.ha.ServiceRestarter + brooklyn.enrichers: + - type: brooklyn.policy.ha.ServiceFailureDetector + brooklyn.policies: + - type: brooklyn.policy.ha.ServiceReplacer http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/simple-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/simple-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/simple-cassandra-cluster.yaml new file mode 100644 index 0000000..ff7b48c --- /dev/null +++ b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/simple-cassandra-cluster.yaml @@ -0,0 +1,28 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# A YAML version of the SimpleCassandraCluster application +# +name: Simple Cassandra cluster +location: localhost + +services: +- type: brooklyn.entity.nosql.cassandra.CassandraDatacenter + name: Brooklyn + brooklyn.config: + initialSize: 1 http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/44d2dc11/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/wide-area-cassandra-cluster.yaml ---------------------------------------------------------------------- diff --git a/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/wide-area-cassandra-cluster.yaml b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/wide-area-cassandra-cluster.yaml new file mode 100644 index 0000000..3e44e39 --- /dev/null +++ b/examples/simple-nosql-cluster/src/main/resources/org/apache/brooklyn/demo/wide-area-cassandra-cluster.yaml @@ -0,0 +1,41 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. +# +# A YAML version of the WideAreaCassandraCluster application +# +name: Wide Area Cassandra cluster +locations: +- aws-ec2:us-east-1 +- rackspace-cloudservers-uk + +services: +- type: brooklyn.entity.nosql.cassandra.CassandraFabric + name: Brooklyn + brooklyn.config: + initialSize: 2 + snitchName: brooklyn.entity.nosql.cassandra.customsnitch.MultiCloudSnitch + customSnitchJarUrl: classpath://brooklyn/entity/nosql/cassandra/cassandra-multicloud-snitch.jar + memberSpec: + $brooklyn:entitySpec: + type: brooklyn.entity.nosql.cassandra.CassandraNode + brookyn.policies: + - type: brooklyn.policy.ha.ServiceRestarter + brooklyn.enrichers: + - type: brooklyn.policy.ha.ServiceFailureDetector + brooklyn.policies: + - type: brooklyn.policy.ha.ServiceReplacer
