Merge branch 'docker-grouping-merge'
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/8380cc30 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/8380cc30 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/8380cc30 Branch: refs/heads/master Commit: 8380cc30b3539ed466849f8b46abc754f7b02275 Parents: 35cd74a 3681388 Author: Imesh Gunaratne <[email protected]> Authored: Sun Nov 9 23:54:06 2014 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Sun Nov 9 23:54:06 2014 +0530 ---------------------------------------------------------------------- .../org.apache.stratos.autoscaler/pom.xml | 340 +-- .../autoscaler/AbstractClusterContext.java | 57 + .../stratos/autoscaler/AutoscalerContext.java | 42 +- .../apache/stratos/autoscaler/Constants.java | 13 + .../autoscaler/KubernetesClusterContext.java | 40 +- .../autoscaler/NetworkPartitionContext.java | 181 +- .../stratos/autoscaler/PartitionContext.java | 151 +- .../stratos/autoscaler/VMClusterContext.java | 117 + .../autoscaler/VMServiceClusterContext.java | 55 + .../algorithm/AutoscaleAlgorithm.java | 2 +- .../InstanceCountRoundingAlgorithm.java | 12 + .../autoscaler/algorithm/OneAfterAnother.java | 2 +- .../autoscaler/api/AutoScalerServiceImpl.java | 153 +- .../applications/ApplicationHolder.java | 122 + .../ApplicationSynchronizeTask.java | 55 + .../ApplicationSynchronizerTaskScheduler.java | 87 + .../applications/ApplicationUtils.java | 301 +++ .../applications/ClusterInformation.java | 27 + .../applications/MTClusterInformation.java | 45 + .../applications/STClusterInformation.java | 55 + .../dependency/DependencyBuilder.java | 156 ++ .../applications/dependency/DependencyTree.java | 263 ++ .../dependency/context/ApplicationContext.java | 113 + .../context/ApplicationContextFactory.java | 101 + .../dependency/context/ClusterContext.java | 38 + .../dependency/context/GroupContext.java | 25 + .../applications/parser/ApplicationParser.java | 57 + .../parser/DefaultApplicationParser.java | 734 ++++++ .../applications/parser/ParserUtils.java | 142 ++ .../ApplicationCartridgePayloadData.java | 27 + .../applications/payload/BasicPayloadData.java | 311 +++ .../payload/DataCartridgePayloadData.java | 27 + .../payload/FrameworkCartridgePayloadData.java | 27 + .../LoadBalancerCartridgePayloadData.java | 27 + .../applications/payload/PayloadData.java | 69 + .../applications/payload/PayloadFactory.java | 59 + .../pojo/ApplicationClusterContext.java | 149 ++ .../applications/pojo/ApplicationContext.java | 112 + .../applications/pojo/ComponentContext.java | 58 + .../applications/pojo/DependencyContext.java | 48 + .../applications/pojo/GroupContext.java | 88 + .../applications/pojo/SubscribableContext.java | 47 + .../pojo/SubscribableInfoContext.java | 119 + .../applications/topic/ApplicationBuilder.java | 467 ++++ .../topic/ApplicationsEventPublisher.java | 127 + .../client/CloudControllerClient.java | 398 +++ .../client/InstanceNotificationClient.java | 71 + .../cloud/controller/CloudControllerClient.java | 347 --- .../controller/InstanceNotificationClient.java | 71 - .../commands/DeploymentPolicyCommands.java | 2 +- .../deployment/policy/DeploymentPolicy.java | 179 -- .../publisher/ClusterStatusEventPublisher.java | 197 ++ .../InstanceNotificationPublisher.java | 57 + .../AutoscalerHealthStatEventReceiver.java | 527 ++++ .../AutoscalerTopologyEventReceiver.java | 492 ++++ .../ApplicationDefinitionException.java | 48 + .../CartridgeInformationException.java | 47 + .../exception/DependencyBuilderException.java | 48 + .../exception/InvalidServiceGroupException.java | 46 + .../TopologyInConsistentException.java | 47 + .../interfaces/AutoScalerServiceInterface.java | 37 +- .../internal/AutoscalerServerComponent.java | 61 +- .../AutoscalerHealthStatEventReceiver.java | 500 ---- .../AutoscalerTopologyEventReceiver.java | 401 ---- .../monitor/AbstractClusterMonitor.java | 247 -- .../monitor/ClusterMonitorFactory.java | 444 ---- .../autoscaler/monitor/EventHandler.java | 56 + .../monitor/KubernetesClusterMonitor.java | 510 ---- .../KubernetesServiceClusterMonitor.java | 202 -- .../stratos/autoscaler/monitor/Monitor.java | 108 + .../monitor/MonitorStatusEventBuilder.java | 61 + .../monitor/ParentComponentMonitor.java | 423 ++++ .../autoscaler/monitor/VMClusterMonitor.java | 639 ----- .../autoscaler/monitor/VMLbClusterMonitor.java | 175 -- .../monitor/VMServiceClusterMonitor.java | 235 -- .../monitor/application/ApplicationMonitor.java | 200 ++ .../application/ApplicationMonitorFactory.java | 219 ++ .../monitor/cluster/AbstractClusterMonitor.java | 371 +++ .../monitor/cluster/ClusterMonitorFactory.java | 457 ++++ .../cluster/KubernetesClusterMonitor.java | 514 ++++ .../KubernetesServiceClusterMonitor.java | 214 ++ .../monitor/cluster/VMClusterMonitor.java | 677 ++++++ .../monitor/cluster/VMLbClusterMonitor.java | 175 ++ .../cluster/VMServiceClusterMonitor.java | 216 ++ .../monitor/events/ApplicationStatusEvent.java | 42 + .../monitor/events/ClusterStatusEvent.java | 42 + .../monitor/events/GroupStatusEvent.java | 41 + .../monitor/events/GroupTerminateAllEvent.java | 29 + .../autoscaler/monitor/events/MonitorEvent.java | 28 + .../monitor/events/MonitorScalingEvent.java | 30 + .../monitor/events/MonitorStartAllEvent.java | 28 + .../monitor/events/MonitorStatusEvent.java | 41 + .../events/MonitorTerminateAllEvent.java | 29 + .../autoscaler/monitor/group/GroupMonitor.java | 177 ++ .../autoscaler/partition/PartitionGroup.java | 1 - .../autoscaler/partition/PartitionManager.java | 4 +- .../partition/deployers/PartitionDeployer.java | 117 - .../partition/deployers/PartitionReader.java | 154 -- .../stratos/autoscaler/pojo/Dependencies.java | 46 + .../stratos/autoscaler/pojo/ServiceGroup.java | 67 + .../autoscaler/policy/PolicyManager.java | 2 +- .../policy/deployers/AbstractPolicyReader.java | 93 - .../deployers/DeploymentPolicyDeployer.java | 114 - .../deployers/DeploymentPolicyReader.java | 130 - .../policy/model/DeploymentPolicy.java | 179 ++ .../autoscaler/registry/RegistryManager.java | 223 +- .../rule/AutoscalerRuleEvaluator.java | 88 +- .../autoscaler/rule/RuleTasksDelegator.java | 117 +- .../status/checker/StatusChecker.java | 539 +++++ .../autoscaler/util/AutoScalerConstants.java | 5 +- .../stratos/autoscaler/util/AutoscalerUtil.java | 218 ++ .../stratos/autoscaler/util/Deserializer.java | 10 +- .../autoscaler/util/ServiceReferenceHolder.java | 12 +- .../src/main/resources/META-INF/component.xml | 16 - .../policy/DeploymentPolicyDeployerTest.java | 52 - .../policy/PartitionDeployerTest.java | 65 - .../src/test/resources/autoscaler-old.drl | 2 +- .../src/test/resources/autoscaler.drl | 4 +- .../test/resources/minimum-autoscaler-rule.drl | 2 +- .../resources/test-minimum-autoscaler-rule.drl | 4 +- .../test-terminating-obsoleted-members-rule.drl | 4 +- .../termination-change.patch | 596 +++++ .../stratos/cartridge/agent/CartridgeAgent.java | 11 + .../apache/stratos/cartridge/agent/Main.java | 6 + .../git/impl/GitBasedArtifactRepository.java | 47 - .../publisher/CartridgeStatistics.java | 66 + .../publisher/HealthStatisticsNotifier.java | 119 +- .../publisher/HealthStatisticsReader.java | 31 +- .../publisher/IHealthStatisticsReader.java | 55 + .../statistics/publisher/PluginLoader.java | 88 + .../java/org/apache/stratos/cli/RestClient.java | 1 + .../stratos/cli/RestCommandLineService.java | 222 +- .../apache/stratos/cli/StratosApplication.java | 36 +- .../grouping/applications/Application.java | 70 + .../grouping/applications/ApplicationBean.java | 34 + .../beans/grouping/applications/Cluster.java | 81 + .../cli/beans/grouping/applications/Group.java | 82 + .../cli/beans/grouping/applications/Member.java | 130 + .../beans/grouping/applications/Property.java | 46 + .../beans/grouping/applications/SubGroup.java | 70 + .../grouping/serviceGroups/Dependencies.java | 46 + .../serviceGroups/ServiceGroupBean.java | 33 + .../serviceGroups/ServiceGroupDefinition.java | 70 + .../cli/commands/DeployApplicationCommand.java | 111 + .../commands/DeployKubernetesGroupCommand.java | 1 + .../commands/DeployKubernetesHostCommand.java | 1 + .../cli/commands/DeployServiceGroupCommand.java | 111 + .../commands/DescribeApplicationCommand.java | 67 + .../commands/DescribeServiceGroupCommand.java | 67 + .../cli/commands/ListApplicationsCommand.java | 65 + .../ListCartridgeSubscriptionsCommand.java | 1 + .../cli/commands/ListDeployServiceCommand.java | 65 - .../cli/commands/ListServicesCommand.java | 65 + .../cli/commands/SubscribeCartridgeCommand.java | 3 +- .../commands/UndeployApplicationCommand.java | 76 + .../commands/UndeployServiceGroupCommand.java | 76 + .../cli/commands/UnsubscribeCommand.java | 1 + .../src/main/resources/log4j.properties | 2 +- .../src/test/python/test_interactive.py | 18 +- .../org.apache.stratos.cloud.controller/pom.xml | 7 + .../deployment/partition/Partition.java | 4 +- ...ApplicationClusterRegistrationException.java | 47 + .../ApplicationDefinitionException.java | 47 + ...CompositeApplicationDefinitionException.java | 44 + .../exception/InvalidServiceGroupException.java | 46 + ...inerClusterContextToKubernetesContainer.java | 5 +- .../cloud/controller/iaases/AWSEC2Iaas.java | 4 + .../controller/iaases/OpenstackNovaIaas.java | 3 + .../impl/CloudControllerServiceImpl.java | 2263 ++++++++++-------- .../interfaces/CloudControllerService.java | 50 +- .../internal/CloudControllerDSComponent.java | 214 +- .../pojo/ApplicationClusterContextDTO.java | 143 ++ .../cloud/controller/pojo/Cartridge.java | 16 +- .../cloud/controller/pojo/CartridgeConfig.java | 12 + .../cloud/controller/pojo/CartridgeInfo.java | 1 + .../cloud/controller/pojo/ClusterContext.java | 6 +- .../pojo/CompositeApplicationDefinition.java | 38 + .../cloud/controller/pojo/ConfigCartridge.java | 17 + .../controller/pojo/ConfigDependencies.java | 29 + .../controller/pojo/ConfigDependencyPair.java | 29 + .../cloud/controller/pojo/ConfigGroup.java | 35 + .../pojo/ContainerClusterContext.java | 2 + .../cloud/controller/pojo/Dependencies.java | 48 + .../cloud/controller/pojo/IaasConfig.java | 4 +- .../controller/pojo/LoadbalancerConfig.java | 5 +- .../cloud/controller/pojo/MemberContext.java | 2 + .../cloud/controller/pojo/Properties.java | 52 - .../stratos/cloud/controller/pojo/Property.java | 62 - .../cloud/controller/pojo/Registrant.java | 2 + .../cloud/controller/pojo/ServiceGroup.java | 69 + .../controller/pojo/payload/MetaDataHolder.java | 99 + .../application/ApplicationTopicReceiver.java | 81 + .../status/ClusterStatusTopicReceiver.java | 107 + .../status/InstanceStatusTopicReceiver.java | 113 + .../runtime/FasterLookUpDataHolder.java | 37 +- .../InstanceStatusEventMessageDelegator.java | 79 - .../InstanceStatusEventMessageListener.java | 84 - .../status/InstanceStatusEventMessageQueue.java | 45 - .../controller/topology/TopologyBuilder.java | 389 ++- .../topology/TopologyEventPublisher.java | 551 +++-- .../controller/util/CloudControllerUtil.java | 31 +- .../CompositeApplicationParseTest.java | 554 +++++ .../org/apache/stratos/common/Properties.java | 85 + .../org/apache/stratos/common/Property.java | 109 + .../common/constants/StratosConstants.java | 2 + .../common/kubernetes/KubernetesGroup.java | 2 + .../common/kubernetes/KubernetesHost.java | 1 + .../stratos/common/kubernetes/Properties.java | 80 - .../stratos/common/kubernetes/Property.java | 101 - .../LoadBalancerStatisticsReader.java | 5 + .../LoadBalancerStatisticsNotifier.java | 11 +- .../WSO2CEPInFlightRequestPublisher.java | 7 +- .../org.apache.stratos.load.balancer/pom.xml | 45 - .../LoadBalancerTopologyEventReceiver.java | 77 +- .../conf/LoadBalancerConfiguration.java | 9 +- .../LoadBalancerStatisticsCollector.java | 38 + .../behaviour/CartridgeMgtBehaviour.java | 3 +- .../manager/client/AutoscalerServiceClient.java | 41 +- .../client/CloudControllerServiceClient.java | 40 +- .../composite/application/TemporyClass.java | 7 - .../beans/ApplicationDefinition.java | 78 + .../application/beans/ComponentDefinition.java | 41 + .../application/beans/GroupDefinition.java | 87 + .../application/beans/PropertyBean.java | 46 + .../beans/SubscribableDefinition.java | 48 + .../application/beans/SubscribableInfo.java | 118 + .../ApplicationSubscriptionException.java | 51 + ...CompositeApplicationDefinitionException.java | 47 + .../CompositeApplicationException.java | 47 + .../DomainSubscriptionDoesNotExist.java | 39 +- .../exception/GroupSubscriptionException.java | 47 + .../exception/InvalidServiceGroupException.java | 47 + .../ServiceGroupDefinitioException.java | 47 + .../definitions/DependencyDefinitions.java | 53 + .../definitions/ServiceGroupDefinition.java | 68 + .../definitions/StartupOrderDefinition.java | 47 + .../deployer/DefaultServiceGroupDeployer.java | 343 +++ .../grouping/deployer/ServiceGroupDeployer.java | 36 + .../manager/ServiceGroupingManager.java | 57 + .../internal/ADCManagementServerComponent.java | 12 + .../category/ExistingLoadBalancerCategory.java | 2 +- .../manager/CartridgeSubscriptionManager.java | 206 +- .../manager/persistence/PersistenceManager.java | 26 + .../RegistryBasedPersistenceManager.java | 396 ++- .../DataInsertionAndRetrievalManager.java | 49 + .../subscription/ApplicationSubscription.java | 78 + .../subscription/DataCartridgeSubscription.java | 2 +- .../manager/subscription/GroupSubscription.java | 73 + .../subscription/LBCartridgeSubscription.java | 1 - .../manager/subscription/SubscriptionData.java | 1 - .../SubscriptionMultiTenantBehaviour.java | 2 +- .../utils/CartridgeSubscriptionUtils.java | 2 +- .../StratosManagerTopologyEventReceiver.java | 228 +- .../utils/ApplicationManagementUtil.java | 2 +- .../stratos/manager/utils/Serializer.java | 53 +- components/org.apache.stratos.messaging/pom.xml | 46 +- .../messaging/broker/connect/MQTTConnector.java | 89 +- .../broker/publish/TopicPublisher.java | 60 +- .../broker/subscribe/TopicSubscriber.java | 32 +- .../domain/applications/Application.java | 124 + .../domain/applications/ApplicationStatus.java | 74 + .../domain/applications/Applications.java | 73 + .../domain/applications/ClusterDataHolder.java | 50 + .../domain/applications/DependencyOrder.java | 52 + .../messaging/domain/applications/Group.java | 119 + .../domain/applications/GroupStatus.java | 73 + .../domain/applications/ParentComponent.java | 212 ++ .../domain/applications/StartupOrder.java | 40 + .../applications/locking/ApplicationLock.java | 59 + .../locking/ApplicationLockHierarchy.java | 91 + .../domain/exception/MessagingException.java | 40 + .../messaging/domain/topology/Cartridge.java | 89 + .../messaging/domain/topology/Cluster.java | 109 +- .../domain/topology/ClusterStatus.java | 54 +- .../messaging/domain/topology/Composite.java | 15 + .../domain/topology/CompositeApplication.java | 298 +++ .../domain/topology/ConfigCartridge.java | 20 + .../topology/ConfigCompositeApplication.java | 42 + .../domain/topology/ConfigDependencies.java | 57 + .../messaging/domain/topology/ConfigGroup.java | 33 + .../messaging/domain/topology/Dependencies.java | 334 +++ .../messaging/domain/topology/GroupTemp.java | 503 ++++ .../LifeCycleStateTransitionBehavior.java | 35 + .../messaging/domain/topology/Member.java | 31 +- .../messaging/domain/topology/MemberStatus.java | 62 +- .../messaging/domain/topology/Scalable.java | 5 + .../messaging/domain/topology/Service.java | 9 +- .../messaging/domain/topology/Subscribable.java | 25 + .../messaging/domain/topology/Topology.java | 15 +- .../topology/lifecycle/LifeCycleState.java | 28 + .../lifecycle/LifeCycleStateManager.java | 138 ++ .../domain/topology/locking/TopologyLock.java | 63 + .../topology/locking/TopologyLockHierarchy.java | 134 ++ .../applications/ApplicationActivatedEvent.java | 40 + .../applications/ApplicationCreatedEvent.java | 41 + .../ApplicationInactivatedEvent.java | 40 + .../ApplicationTerminatedEvent.java | 48 + .../ApplicationTerminatingEvent.java | 40 + .../applications/CompleteApplicationsEvent.java | 44 + .../event/applications/GroupActivatedEvent.java | 48 + .../applications/GroupInactivatedEvent.java | 43 + .../applications/GroupMaintenanceModeEvent.java | 45 + .../applications/GroupReadyToShutdownEvent.java | 44 + .../event/applications/GroupResetEvent.java | 48 + .../applications/GroupTerminatedEvent.java | 48 + .../applications/GroupTerminatingEvent.java | 48 + .../ClusterStatusClusterActivatedEvent.java | 52 + .../ClusterStatusClusterCreatedEvent.java | 85 + .../ClusterStatusClusterInactivateEvent.java | 52 + .../status/ClusterStatusClusterResetEvent.java | 52 + .../ClusterStatusClusterTerminatedEvent.java | 52 + .../ClusterStatusClusterTerminatingEvent.java | 52 + .../stat/AverageRequestsInFlightEvent.java | 11 +- .../AverageRequestsServingCapabilityEvent.java | 31 + .../instance/status/InstanceActivatedEvent.java | 9 + .../status/InstanceMaintenanceModeEvent.java | 9 + .../status/InstanceReadyToShutdownEvent.java | 9 + .../instance/status/InstanceStartedEvent.java | 9 + .../ApplicationClustersCreatedEvent.java | 45 + .../event/topology/ClusterActivatedEvent.java | 57 + .../event/topology/ClusterCreatedEvent.java | 28 +- .../event/topology/ClusterInactivateEvent.java | 56 + .../topology/ClusterMaintenanceModeEvent.java | 58 - .../event/topology/ClusterResetEvent.java | 56 + .../event/topology/ClusterTerminatedEvent.java | 56 + .../event/topology/ClusterTerminatingEvent.java | 56 + .../CompositeApplicationCreatedEvent.java | 51 + .../topology/CompositeApplicationEvent.java | 31 + .../CompositeApplicationRemovedEvent.java | 49 + .../event/topology/MemberActivatedEvent.java | 42 +- .../topology/MemberMaintenanceModeEvent.java | 9 + .../topology/MemberReadyToShutdownEvent.java | 9 + .../event/topology/MemberStartedEvent.java | 9 + .../event/topology/MemberSuspendedEvent.java | 9 + .../event/topology/MemberTerminatedEvent.java | 8 + .../ApplicationActivatedEventListener.java | 27 + .../ApplicationCreatedEventListener.java | 27 + .../ApplicationInactivatedEventListener.java | 27 + .../ApplicationTerminatedEventListener.java | 27 + .../ApplicationTerminatingEventListener.java | 27 + .../ApplicationUndeployedEventListener.java | 26 + .../CompleteApplicationsEventListener.java | 26 + .../GroupActivatedEventListener.java | 24 + .../GroupInactivateEventListener.java | 24 + .../applications/GroupResetEventListener.java | 24 + .../GroupTerminatedEventListener.java | 24 + .../GroupTerminatingEventListener.java | 24 + ...sterStatusClusterActivatedEventListener.java | 24 + ...lusterStatusClusterCreatedEventListener.java | 24 + ...terStatusClusterInactivateEventListener.java | 24 + .../ClusterStatusClusterResetEventListener.java | 24 + ...terStatusClusterTerminatedEventListener.java | 24 + ...erStatusClusterTerminatingEventListener.java | 24 + ...eRequestsServingCapabilityEventListener.java | 14 + .../status/InstanceActivatedEventListener.java | 26 + .../status/InstanceMaintenanceListener.java | 24 + .../InstanceReadyToShutdownEventListener.java | 25 + .../status/InstanceStartedEventListener.java | 26 + ...ApplicationClustersCreatedEventListener.java | 27 + .../topology/ClusterActivatedEventListener.java | 24 + .../ClusterInActivateEventListener.java | 24 + .../ClusterMaintenanceModeEventListener.java | 25 - .../topology/ClusterResetEventListener.java | 24 + .../ClusterTerminatedEventListener.java | 24 + .../ClusterTerminatingEventListener.java | 24 + .../ApplicationActivatedMessageProcessor.java | 104 + .../ApplicationCreatedMessageProcessor.java | 101 + .../ApplicationInactivatedMessageProcessor.java | 104 + .../ApplicationTerminatedMessageProcessor.java | 132 + .../ApplicationTerminatingMessageProcessor.java | 104 + .../ApplicationsMessageProcessorChain.java | 115 + .../CompleteApplicationsMessageProcessor.java | 98 + .../applications/GroupActivatedProcessor.java | 107 + .../applications/GroupInActivateProcessor.java | 106 + .../applications/GroupResetProcessor.java | 108 + .../applications/GroupTerminatedProcessor.java | 107 + .../applications/GroupTerminatingProcessor.java | 107 + .../updater/ApplicationsUpdater.java | 138 ++ ...rStatusClusterActivatedMessageProcessor.java | 58 + ...terStatusClusterCreatedMessageProcessor.java | 58 + ...StatusClusterInactivateMessageProcessor.java | 58 + ...usterStatusClusterResetMessageProcessor.java | 58 + ...StatusClusterTerminatedMessageProcessor.java | 58 + ...tatusClusterTerminatingMessageProcessor.java | 58 + .../ClusterStatusMessageProcessorChain.java | 84 + ...questsServingCapabilityMessageProcessor.java | 49 + .../stat/HealthStatMessageProcessorChain.java | 5 + ...ceStatusMemberActivatedMessageProcessor.java | 60 + ...StatusMemberMaintenanceMessageProcessor.java | 60 + ...usMemberReadyToShutdownMessageProcessor.java | 60 + ...anceStatusMemberStartedMessageProcessor.java | 60 + .../InstanceStatusMessageProcessorChain.java | 82 + ...licationClustersCreatedMessageProcessor.java | 139 ++ .../topology/ClusterActivatedProcessor.java | 133 + .../ClusterCreatedMessageProcessor.java | 136 +- .../topology/ClusterInActivateProcessor.java | 131 + .../ClusterMaintenanceModeMessageProcessor.java | 115 - .../ClusterRemovedMessageProcessor.java | 105 +- .../topology/ClusterResetMessageProcessor.java | 130 + .../topology/ClusterTerminatedProcessor.java | 133 + .../topology/ClusterTerminatingProcessor.java | 133 + .../CompleteTopologyMessageProcessor.java | 196 +- .../InstanceSpawnedMessageProcessor.java | 151 +- .../MemberActivatedMessageProcessor.java | 184 +- .../MemberMaintenanceModeProcessor.java | 162 +- .../MemberReadyToShutdownMessageProcessor.java | 163 +- .../topology/MemberStartedMessageProcessor.java | 160 +- .../MemberSuspendedMessageProcessor.java | 158 +- .../MemberTerminatedMessageProcessor.java | 139 +- .../ServiceCreatedMessageProcessor.java | 74 +- .../ServiceRemovedMessageProcessor.java | 71 +- .../topology/TopologyMessageProcessorChain.java | 47 +- .../topology/updater/TopologyUpdater.java | 206 ++ .../applications/ApplicationManager.java | 119 + .../ApplicationsEventMessageDelegator.java | 146 ++ .../ApplicationsEventMessageListener.java | 72 + .../ApplicationsEventMessageQueue.java | 26 + .../applications/ApplicationsEventReceiver.java | 83 + .../ClusterStatusEventMessageDelegator.java | 95 + .../ClusterStatusEventMessageListener.java | 90 + .../status/ClusterStatusEventMessageQueue.java | 29 + .../status/ClusterStatusEventReceiver.java | 90 + .../InstanceStatusEventMessageDelegator.java | 95 + .../InstanceStatusEventMessageListener.java | 90 + .../status/InstanceStatusEventMessageQueue.java | 29 + .../status/InstanceStatusEventReceiver.java | 90 + .../topology/TopologyEventMessageDelegator.java | 10 +- .../receiver/topology/TopologyManager.java | 169 +- .../stratos/messaging/util/Constants.java | 20 +- .../org/apache/stratos/messaging/util/Util.java | 66 +- .../topology/locking/TopologyLockingTest.java | 210 ++ .../org.apache.stratos.metadata.client/pom.xml | 67 + .../metadata/client/beans/PropertyBean.java | 65 + .../client/config/MetaDataClientConfig.java | 125 + .../defaults/DefaultMetaDataServiceClient.java | 131 + .../client/defaults/MetaDataServiceClient.java | 69 + .../MetaDataServiceClientException.java | 48 + .../client/exception/RestClientException.java | 48 + .../metadata/client/rest/DefaultRestClient.java | 171 ++ .../client/rest/HTTPConnectionManager.java | 50 + .../metadata/client/rest/RestClient.java | 53 + .../client/util/MetaDataClientConstants.java | 32 + .../org.apache.stratos.metadataservice/pom.xml | 164 ++ .../stratos/metadataservice/Constants.java | 28 + .../stratos/metadataservice/ServiceHolder.java | 84 + .../apache/stratos/metadataservice/Utils.java | 44 + .../annotation/AuthorizationAction.java | 36 + .../annotation/SuperTenantService.java | 34 + .../context/AuthenticationContext.java | 40 + .../definition/ApplicationBean.java | 70 + .../definition/CartridgeMetaData.java | 36 + .../metadataservice/definition/ClusterBean.java | 59 + .../metadataservice/definition/NewProperty.java | 68 + .../definition/PropertyBean.java | 37 + .../exception/MetadataException.java | 9 + .../exception/RestAPIException.java | 70 + ...tractAuthenticationAuthorizationHandler.java | 56 + .../CookieBasedAuthenticationHandler.java | 94 + .../handlers/CustomExceptionMapper.java | 47 + .../CustomThrowableExceptionMapper.java | 44 + .../handlers/GenericExceptionMapper.java | 54 + .../metadataservice/handlers/OAuthHandler.java | 95 + .../handlers/StratosAuthenticationHandler.java | 156 ++ .../handlers/StratosAuthorizingHandler.java | 333 +++ .../metadataservice/listener/TopologyAgent.java | 130 + .../listener/TopologyListener.java | 69 + .../oauth2/ValidationServiceClient.java | 65 + .../registry/CarbonRegistry.java | 192 ++ .../registry/DataRegistryFactory.java | 36 + .../metadataservice/registry/DataStore.java | 40 + .../metadataservice/registry/GRegRegistry.java | 109 + .../security/StratosPrincipal.java | 53 + .../security/StratosSecurityContext.java | 50 + .../metadataservice/services/MetaDataAdmin.java | 188 ++ .../stratos/metadataservice/util/ConfUtil.java | 76 + .../src/main/resources/axis2_client.xml | 299 +++ .../META-INF/webapp-classloading.xml | 35 + .../WEB-INF/cxf-servlet.xml | 46 + .../stratosmetadataservice-test/WEB-INF/web.xml | 40 + .../META-INF/webapp-classloading.xml | 35 + .../WEB-INF/cxf-servlet.xml | 80 + .../stratosmetadataservice/WEB-INF/web.xml | 42 + .../cartridgeagent/__init__.py | 0 .../cartridgeagent/cartridgeagent/__init__.py | 16 + .../cartridgeagent/cartridgeagent/agent.conf | 61 + .../cartridgeagent/cartridgeagent/agent.py | 349 +++ .../cartridgeagent/cartridgeagent/logging.ini | 52 + .../cartridgeagent/modules/__init__.py | 16 + .../modules/artifactmgt/__init__.py | 17 + .../modules/artifactmgt/git/__init__.py | 17 + .../modules/artifactmgt/git/agentgithandler.py | 574 +++++ .../modules/artifactmgt/git/gitrepository.py | 48 + .../artifactmgt/repositoryinformation.py | 37 + .../cartridgeagent/modules/config/__init__.py | 17 + .../config/cartridgeagentconfiguration.py | 346 +++ .../modules/databridge/__init__.py | 17 + .../cartridgeagent/modules/databridge/agent.py | 225 ++ .../modules/databridge/thrift/__init__.py | 17 + .../databridge/thrift/gen/Data/__init__.py | 1 + .../databridge/thrift/gen/Data/constants.py | 8 + .../databridge/thrift/gen/Data/ttypes.py | 320 +++ .../databridge/thrift/gen/Exception/__init__.py | 1 + .../thrift/gen/Exception/constants.py | 8 + .../databridge/thrift/gen/Exception/ttypes.py | 473 ++++ .../ThriftEventTransmissionService-remote | 117 + .../ThriftEventTransmissionService.py | 1143 +++++++++ .../ThriftEventTransmissionService/__init__.py | 1 + .../ThriftEventTransmissionService/constants.py | 8 + .../ThriftEventTransmissionService/ttypes.py | 21 + .../ThriftSecureEventTransmissionService-remote | 131 + .../ThriftSecureEventTransmissionService.py | 1495 ++++++++++++ .../__init__.py | 1 + .../constants.py | 8 + .../ttypes.py | 21 + .../modules/databridge/thrift/gen/__init__.py | 0 .../modules/databridge/thrift/publisher.py | 110 + .../modules/databridge/thrift/thrift/TSCons.py | 35 + .../databridge/thrift/thrift/TSerialization.py | 38 + .../databridge/thrift/thrift/TTornado.py | 153 ++ .../modules/databridge/thrift/thrift/Thrift.py | 170 ++ .../databridge/thrift/thrift/__init__.py | 20 + .../databridge/thrift/thrift/protocol/TBase.py | 81 + .../thrift/thrift/protocol/TBinaryProtocol.py | 261 ++ .../thrift/thrift/protocol/TCompactProtocol.py | 405 ++++ .../thrift/thrift/protocol/TJSONProtocol.py | 552 +++++ .../thrift/thrift/protocol/TProtocol.py | 406 ++++ .../thrift/thrift/protocol/__init__.py | 20 + .../thrift/thrift/protocol/fastbinary.c | 1219 ++++++++++ .../thrift/thrift/server/THttpServer.py | 87 + .../thrift/thrift/server/TNonblockingServer.py | 346 +++ .../thrift/thrift/server/TProcessPoolServer.py | 118 + .../databridge/thrift/thrift/server/TServer.py | 269 +++ .../databridge/thrift/thrift/server/__init__.py | 20 + .../thrift/thrift/transport/THttpClient.py | 147 ++ .../thrift/thrift/transport/TSSLSocket.py | 214 ++ .../thrift/thrift/transport/TSocket.py | 176 ++ .../thrift/thrift/transport/TTransport.py | 330 +++ .../thrift/thrift/transport/TTwisted.py | 221 ++ .../thrift/thrift/transport/TZlibTransport.py | 249 ++ .../thrift/thrift/transport/__init__.py | 20 + .../modules/datapublisher/__init__.py | 18 + .../modules/datapublisher/exception/__init__.py | 17 + .../exception/datapublisherexception.py | 33 + .../modules/datapublisher/logpublisher.py | 273 +++ .../cartridgeagent/modules/event/__init__.py | 0 .../modules/event/instance/__init__.py | 16 + .../modules/event/instance/notifier/__init__.py | 17 + .../modules/event/instance/notifier/events.py | 77 + .../modules/event/instance/status/__init__.py | 17 + .../modules/event/instance/status/events.py | 98 + .../modules/event/tenant/__init__.py | 16 + .../modules/event/tenant/events.py | 147 ++ .../modules/event/topology/__init__.py | 17 + .../modules/event/topology/events.py | 280 +++ .../modules/exception/__init__.py | 16 + .../exception/parameternotfoundexception.py | 35 + .../modules/extensions/__init__.py | 16 + .../extensions/abstractextensionhandler.py | 78 + .../extensions/defaultextensionhandler.py | 793 ++++++ .../modules/healthstatspublisher/__init__.py | 16 + .../abstracthealthstatisticspublisher.py | 62 + .../modules/healthstatspublisher/healthstats.py | 249 ++ .../modules/publisher/__init__.py | 16 + .../publisher/cartridgeagentpublisher.py | 165 ++ .../modules/subscriber/__init__.py | 17 + .../modules/subscriber/eventsubscriber.py | 96 + .../cartridgeagent/modules/tenant/__init__.py | 16 + .../modules/tenant/tenantcontext.py | 184 ++ .../cartridgeagent/modules/topology/__init__.py | 16 + .../modules/topology/topologycontext.py | 454 ++++ .../cartridgeagent/modules/util/__init__.py | 16 + .../modules/util/asyncscheduledtask.py | 71 + .../modules/util/cartridgeagentconstants.py | 135 ++ .../modules/util/cartridgeagentutils.py | 168 ++ .../modules/util/extensionutils.py | 494 ++++ .../cartridgeagent/modules/util/log.py | 55 + .../cartridgeagent/tests/__init__.py | 16 + .../cartridgeagent/tests/asynctest.txt | 1 + .../cartridgeagent/tests/test_util.py | 133 + .../pom.xml | 58 + .../org.apache.stratos.rest.endpoint/pom.xml | 6 +- .../stratos/rest/endpoint/api/AbstractApi.java | 68 + .../rest/endpoint/api/AuthenticationApi.java | 66 + .../rest/endpoint/api/StratosApiV40.java | 1120 +++++++++ .../rest/endpoint/api/StratosApiV40Utils.java | 1263 ++++++++++ .../rest/endpoint/api/StratosApiV41.java | 1535 ++++++++++++ .../rest/endpoint/api/StratosApiV41Utils.java | 1819 ++++++++++++++ .../rest/endpoint/bean/ApplicationBean.java | 49 + .../rest/endpoint/bean/CartridgeInfoBean.java | 3 +- .../stratos/rest/endpoint/bean/GroupBean.java | 86 + .../endpoint/bean/StratosAdminResponse.java | 36 - .../rest/endpoint/bean/StratosApiResponse.java | 36 + .../definition/CartridgeDefinitionBean.java | 13 +- .../rest/endpoint/bean/topology/Cluster.java | 2 +- .../bean/util/converter/PojoConverter.java | 234 +- ...tractAuthenticationAuthorizationHandler.java | 4 +- .../handlers/CustomExceptionMapper.java | 2 +- .../CustomThrowableExceptionMapper.java | 4 +- .../handlers/StratosAuthenticationHandler.java | 22 +- .../handlers/StratosAuthorizingHandler.java | 4 +- .../stratos/rest/endpoint/mock/MockContext.java | 108 +- .../rest/endpoint/mock/StratosApiV40Mock.java | 578 +++++ .../rest/endpoint/mock/StratosTestAdmin.java | 593 ----- .../rest/endpoint/services/AbstractAdmin.java | 68 - .../endpoint/services/AuthenticationAdmin.java | 67 - .../stratos/rest/endpoint/services/MyType.java | 16 - .../rest/endpoint/services/ServiceUtils.java | 1551 ------------ .../rest/endpoint/services/StratosAdmin.java | 1422 ----------- .../api-test/META-INF/webapp-classloading.xml | 35 + .../webapp/api-test/WEB-INF/cxf-servlet.xml | 98 + .../webapp/api-test/WEB-INF/schemas/schema.xsd | 249 ++ .../src/main/webapp/api-test/WEB-INF/web.xml | 40 + .../webapp/api/META-INF/webapp-classloading.xml | 35 + .../src/main/webapp/api/WEB-INF/cxf-servlet.xml | 135 ++ .../main/webapp/api/WEB-INF/schemas/schema.xsd | 333 +++ .../src/main/webapp/api/WEB-INF/web.xml | 39 + .../META-INF/webapp-classloading.xml | 35 - .../webapp/stratos-test/WEB-INF/cxf-servlet.xml | 84 - .../stratos-test/WEB-INF/schemas/schema.xsd | 249 -- .../main/webapp/stratos-test/WEB-INF/web.xml | 40 - .../stratos/META-INF/webapp-classloading.xml | 35 - .../main/webapp/stratos/WEB-INF/cxf-servlet.xml | 94 - .../webapp/stratos/WEB-INF/schemas/schema.xsd | 266 -- .../src/main/webapp/stratos/WEB-INF/web.xml | 40 - components/pom.xml | 7 +- .../AverageInFlightRequestsEventFormatter.xml | 2 +- .../AverageServedRequestsEventFormatter.xml | 32 + .../AverageInFlightRequestsFinder.xml | 15 +- .../streamdefinitions/stream-manager-config.xml | 20 +- ...equestHandlingCapabilityWindowProcessor.java | 49 + .../extension/HAProxyStatisticsReader.java | 10 + .../pom.xml | 111 + features/common/pom.xml | 37 + .../pom.xml | 320 +++ .../src/main/resources/p2.inf | 23 + .../src/main/resources/tomcat/context.xml | 36 + .../tomcat/webapp-classloading-environments.xml | 68 + .../resources/tomcat/webapp-classloading.xml | 33 + features/manager/pom.xml | 1 + .../pom.xml | 12 +- .../src/main/resources/p2.inf | 2 +- features/pom.xml | 1 + .../conf/templates/jndi.properties.template | 27 + products/python-cartridge-agent/pom.xml | 0 .../modules/distribution/src/assembly/bin.xml | 24 +- .../modules/distribution/src/bin/stratos.sh | 7 +- .../src/main/conf/drools/container-mincheck.drl | 19 - .../conf/drools/container-obsoletecheck.drl | 46 + .../src/main/conf/drools/mincheck.drl | 18 +- .../src/main/conf/drools/obsoletecheck.drl | 66 + .../src/main/conf/drools/scaling.drl | 29 +- .../main/conf/drools/terminatedependency.drl | 52 + .../src/main/conf/metadataservice.xml | 43 + .../src/main/conf/siddhi/siddhi.extension | 1 + .../distribution/src/main/license/LICENSE | 4 +- products/stratos/modules/p2-profile-gen/pom.xml | 48 +- products/stratos/pom.xml | 1 + .../pom.xml | 11 +- .../src/main/resources/AutoScalerService.wsdl | 866 +++++-- .../pom.xml | 12 +- .../main/resources/CloudControllerService.wsdl | 596 ++++- .../deployment_script.sh | 36 + .../m1-samples/ec2/autoscale-policy.json | 14 + .../m1-samples/ec2/deployment-policy.json | 14 + .../ec2/m1_single_subsciption_app.json | 19 + .../m1-samples/ec2/p1.json | 10 + .../m1-samples/ec2/php-cart.json | 38 + .../m1-samples/os/autoscale-policy.json | 14 + .../m1-samples/os/deployment-policy.json | 14 + .../os/m1_single_subsciption_app.json | 19 + .../m1-samples/os/p1.json | 10 + .../m1-samples/os/php-cart.json | 46 + .../samples/ec2/autoscale-policy 2.json | 17 + .../samples/ec2/autoscale-policy.json | 14 + .../samples/ec2/deployment-policy 2.json | 14 + .../samples/ec2/deployment-policy.json | 14 + .../samples/ec2/group1.json | 9 + .../samples/ec2/group2.json | 15 + .../samples/ec2/m1_single_subsciption_app.json | 19 + .../samples/ec2/m2_single_subsciption_app.json | 95 + .../samples/ec2/mysql.json | 33 + .../samples/ec2/mytest.json | 33 + .../samples/ec2/p1.json | 10 + .../samples/ec2/php-cart.json | 38 + .../samples/ec2/tomcat.json | 33 + .../samples/ec2/tomcat1.json | 33 + .../samples/os/autoscale-policy.json | 14 + .../samples/os/deployment-policy.json | 14 + .../samples/os/m1_single_subsciption_app.json | 19 + .../samples/os/p1.json | 10 + .../samples/os/php-cart.json | 46 + tools/puppet3/manifests/nodes/default.pp | 4 +- tools/puppet3/modules/haproxy/manifests/init.pp | 4 +- tools/puppet3/modules/jboss/manifests/init.pp | 4 +- tools/puppet3/modules/lb/manifests/init.pp | 4 +- tools/puppet3/modules/mysql/manifests/init.pp | 4 +- .../mysql/templates/instance-activated.sh.erb | 28 + .../mysql/templates/instance-started.sh.erb | 43 + .../templates/mysql_root_password_setter.sh.erb | 16 + .../mysql/templates/publish-metadata.py.erb | 95 + tools/puppet3/modules/nodejs/manifests/init.pp | 4 +- tools/puppet3/modules/php/manifests/init.pp | 4 +- .../modules/python_agent/files/README.txt | 12 + .../lib/puppet/parser/functions/difference.rb | 38 + .../modules/python_agent/manifests/init.pp | 145 ++ .../python_agent/manifests/initialize.pp | 100 + .../python_agent/manifests/push_templates.pp | 28 + .../python_agent/manifests/remove_templates.pp | 24 + .../modules/python_agent/manifests/start.pp | 27 + .../python_agent/templates/agent.conf.erb | 42 + .../templates/extensions/artifacts-copy.sh.erb | 29 + .../extensions/artifacts-updated.sh.erb | 34 + .../templates/extensions/clean.sh.erb | 28 + .../templates/extensions/complete-tenant.sh.erb | 30 + .../extensions/complete-topology.sh.erb | 34 + .../extensions/instance-activated.sh.erb | 28 + .../extensions/instance-started.sh.erb | 27 + .../extensions/member-activated.sh.erb | 303 +++ .../templates/extensions/member-started.sh.erb | 43 + .../extensions/member-suspended.sh.erb | 43 + .../extensions/member-terminated.sh.erb | 43 + .../templates/extensions/mount-volumes.sh.erb | 87 + .../templates/extensions/start-servers.sh.erb | 308 +++ .../extensions/subscription-domain-added.sh.erb | 35 + .../subscription-domain-removed.sh.erb | 34 + .../python_agent/templates/logging.ini.erb | 34 + tools/puppet3/modules/ruby/manifests/init.pp | 4 +- tools/puppet3/modules/tomcat/manifests/init.pp | 4 +- .../puppet3/modules/wordpress/manifests/init.pp | 4 +- tools/python_cartridgeagent/__init__.py | 0 .../cartridgeagent/__init__.py | 16 - .../cartridgeagent/agent.conf | 61 - .../cartridgeagent/agent.py | 349 --- .../cartridgeagent/logging.ini | 52 - .../cartridgeagent/modules/__init__.py | 16 - .../modules/artifactmgt/__init__.py | 17 - .../modules/artifactmgt/git/__init__.py | 17 - .../modules/artifactmgt/git/agentgithandler.py | 574 ----- .../modules/artifactmgt/git/gitrepository.py | 48 - .../artifactmgt/repositoryinformation.py | 37 - .../cartridgeagent/modules/config/__init__.py | 17 - .../config/cartridgeagentconfiguration.py | 346 --- .../modules/databridge/__init__.py | 17 - .../cartridgeagent/modules/databridge/agent.py | 225 -- .../modules/databridge/thrift/__init__.py | 17 - .../databridge/thrift/gen/Data/__init__.py | 1 - .../databridge/thrift/gen/Data/constants.py | 8 - .../databridge/thrift/gen/Data/ttypes.py | 320 --- .../databridge/thrift/gen/Exception/__init__.py | 1 - .../thrift/gen/Exception/constants.py | 8 - .../databridge/thrift/gen/Exception/ttypes.py | 473 ---- .../ThriftEventTransmissionService-remote | 117 - .../ThriftEventTransmissionService.py | 1143 --------- .../ThriftEventTransmissionService/__init__.py | 1 - .../ThriftEventTransmissionService/constants.py | 8 - .../ThriftEventTransmissionService/ttypes.py | 21 - .../ThriftSecureEventTransmissionService-remote | 131 - .../ThriftSecureEventTransmissionService.py | 1495 ------------ .../__init__.py | 1 - .../constants.py | 8 - .../ttypes.py | 21 - .../modules/databridge/thrift/gen/__init__.py | 0 .../modules/databridge/thrift/publisher.py | 110 - .../modules/databridge/thrift/thrift/TSCons.py | 35 - .../databridge/thrift/thrift/TSerialization.py | 38 - .../databridge/thrift/thrift/TTornado.py | 153 -- .../modules/databridge/thrift/thrift/Thrift.py | 170 -- .../databridge/thrift/thrift/__init__.py | 20 - .../databridge/thrift/thrift/protocol/TBase.py | 81 - .../thrift/thrift/protocol/TBinaryProtocol.py | 261 -- .../thrift/thrift/protocol/TCompactProtocol.py | 405 ---- .../thrift/thrift/protocol/TJSONProtocol.py | 552 ----- .../thrift/thrift/protocol/TProtocol.py | 406 ---- .../thrift/thrift/protocol/__init__.py | 20 - .../thrift/thrift/protocol/fastbinary.c | 1219 ---------- .../thrift/thrift/server/THttpServer.py | 87 - .../thrift/thrift/server/TNonblockingServer.py | 346 --- .../thrift/thrift/server/TProcessPoolServer.py | 118 - .../databridge/thrift/thrift/server/TServer.py | 269 --- .../databridge/thrift/thrift/server/__init__.py | 20 - .../thrift/thrift/transport/THttpClient.py | 147 -- .../thrift/thrift/transport/TSSLSocket.py | 214 -- .../thrift/thrift/transport/TSocket.py | 176 -- .../thrift/thrift/transport/TTransport.py | 330 --- .../thrift/thrift/transport/TTwisted.py | 221 -- .../thrift/thrift/transport/TZlibTransport.py | 249 -- .../thrift/thrift/transport/__init__.py | 20 - .../modules/datapublisher/__init__.py | 18 - .../modules/datapublisher/exception/__init__.py | 17 - .../exception/datapublisherexception.py | 33 - .../modules/datapublisher/logpublisher.py | 273 --- .../cartridgeagent/modules/event/__init__.py | 0 .../modules/event/instance/__init__.py | 16 - .../modules/event/instance/notifier/__init__.py | 17 - .../modules/event/instance/notifier/events.py | 77 - .../modules/event/instance/status/__init__.py | 17 - .../modules/event/instance/status/events.py | 98 - .../modules/event/tenant/__init__.py | 16 - .../modules/event/tenant/events.py | 147 -- .../modules/event/topology/__init__.py | 17 - .../modules/event/topology/events.py | 280 --- .../modules/exception/__init__.py | 16 - .../exception/parameternotfoundexception.py | 35 - .../modules/extensions/__init__.py | 16 - .../extensions/abstractextensionhandler.py | 78 - .../extensions/defaultextensionhandler.py | 792 ------ .../modules/healthstatspublisher/__init__.py | 16 - .../abstracthealthstatisticspublisher.py | 62 - .../modules/healthstatspublisher/healthstats.py | 249 -- .../modules/publisher/__init__.py | 16 - .../publisher/cartridgeagentpublisher.py | 165 -- .../modules/subscriber/__init__.py | 17 - .../modules/subscriber/eventsubscriber.py | 96 - .../cartridgeagent/modules/tenant/__init__.py | 16 - .../modules/tenant/tenantcontext.py | 184 -- .../cartridgeagent/modules/topology/__init__.py | 16 - .../modules/topology/topologycontext.py | 454 ---- .../cartridgeagent/modules/util/__init__.py | 16 - .../modules/util/asyncscheduledtask.py | 71 - .../modules/util/cartridgeagentconstants.py | 135 -- .../modules/util/cartridgeagentutils.py | 168 -- .../modules/util/extensionutils.py | 494 ---- .../cartridgeagent/modules/util/log.py | 55 - tools/python_cartridgeagent/tests/__init__.py | 16 - tools/python_cartridgeagent/tests/asynctest.txt | 1 - tools/python_cartridgeagent/tests/test_util.py | 133 - tools/stratos-installer/conf/setup.conf | 5 + .../all/repository/conf/metadataservice.xml | 37 + .../config/greg/repository/conf/carbon.xml | 609 +++++ tools/stratos-installer/setup.sh | 29 + tools/stratos-installer/start-servers.sh | 7 +- 831 files changed, 65597 insertions(+), 29471 deletions(-) ----------------------------------------------------------------------
