Examples of Cartridge


Examples of org.apache.stratos.cloud.controller.pojo.Cartridge

        try {
            TopologyManager.acquireWriteLock();
            member.setStatus(MemberStatus.Activated);
            log.info("member started event adding status activated");
            Cartridge cartridge = FasterLookUpDataHolder.getInstance().
                    getCartridge(instanceActivatedEvent.getServiceName());

            List<PortMapping> portMappings = cartridge.getPortMappings();
            Port port;
            //adding ports to the event
            for (PortMapping portMapping : portMappings) {
                port = new Port(portMapping.getProtocol(),
                        Integer.parseInt(portMapping.getPort()),
View Full Code Here

Examples of org.apache.stratos.cloud.controller.util.Cartridge

                                                                     CloudControllerConstants.VERSION_ATTR));

          boolean multiTenant = Boolean.valueOf(cartridgeElement.getAttributeValue(new QName(
              CloudControllerConstants.MULTI_TENANT_ATTR)));

          Cartridge aCartridge;

          if ((aCartridge = dataHolder.getCartridge(type)) == null) {

            aCartridge = new Cartridge(type, host, provider, version, multiTenant);
          }
         
          // read displayName
          Iterator<?> itName =
                           cartridgeElement.getChildrenWithName(new QName(
                                                                          CloudControllerConstants.DISPLAY_NAME_ELEMENT));

          if (itName.hasNext()) {
            OMElement name = (OMElement) itName.next();

            aCartridge.setDisplayName(name.getText());
          }
         
          // read description
          Iterator<?> it =
                           cartridgeElement.getChildrenWithName(new QName(
                                                                          CloudControllerConstants.DESCRIPTION_ELEMENT));

          if (it.hasNext()) {
            OMElement desc = (OMElement) it.next();

            aCartridge.setDescription(desc.getText());
          }

          // load properties of this cartridge
          loadProperties(cartridgeElement, aCartridge.getProperties());

          // retrieve the list of IaaS providers
          List<?> iaasProviderNodes = getMatchingNodes(xpath + CloudControllerConstants.IAAS_PROVIDER_ELEMENT_XPATH,
                                                       cartridgeElement);
View Full Code Here

Examples of org.apache.stratos.cloud.controller.util.Cartridge

  }

  @Override
  public CartridgeInfo getCartridgeInfo(String cartridgeType)
      throws UnregisteredCartridgeException {
    Cartridge cartridge = dataHolder
        .getCartridge(cartridgeType);

    if (cartridge != null) {

      return CloudControllerUtil.toCartridgeInfo(cartridge);
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

                    if (!ServiceUtils.cartridgeMatches(cartridgeInfo, searchPattern)) {
                        continue;
                    }

                    Cartridge cartridge = new Cartridge();
                    cartridge.setCartridgeType(cartridgeType);
                    cartridge.setProvider(cartridgeInfo.getProvider());
                    cartridge.setDisplayName(cartridgeInfo.getDisplayName());
                    cartridge.setDescription(cartridgeInfo.getDescription());
                    cartridge.setVersion(cartridgeInfo.getVersion());
                    cartridge.setMultiTenant(cartridgeInfo.getMultiTenant());
                    cartridge.setHostName(cartridgeInfo.getHostName());
                    cartridge.setDefaultAutoscalingPolicy(cartridgeInfo.getDefaultAutoscalingPolicy());
                    cartridge.setDefaultDeploymentPolicy(cartridgeInfo.getDefaultDeploymentPolicy());
                    //cartridge.setStatus(CartridgeConstants.NOT_SUBSCRIBED);
                    cartridge.setCartridgeAlias("-");
                    cartridge.setPersistence(cartridgeInfo.getPersistence());

                    if(cartridgeInfo.getLbConfig() != null && cartridgeInfo.getProperties() != null) {
                        for(Property property: cartridgeInfo.getProperties()) {
                        if(property.getName().equals("load.balancer")) {
                            cartridge.setLoadBalancer(true);
                        }
                        }
                    }
                    //cartridge.setActiveInstances(0);
                    cartridges.add(cartridge);
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

                for (CartridgeSubscription subscription : subscriptions) {
                 
                    if (!cartridgeMatches(subscription.getCartridgeInfo(), subscription, searchPattern)) {
                        continue;
                    }
                    Cartridge cartridge = getCartridgeFromSubscription(subscription);
                    if (cartridge == null) {
                    continue;
                  }
                    Cluster cluster = TopologyClusterInformationModel.getInstance().getCluster(ApplicationManagementUtil.getTenantId(configurationContext)
                            ,cartridge.getCartridgeType(), cartridge.getCartridgeAlias());
                    String cartridgeStatus = "Inactive";
                    int activeMemberCount = 0;
          if (cluster != null) {
            Collection<Member> members = cluster.getMembers();
            for (Member member : members) {
              if (member.isActive()) {
                cartridgeStatus = "Active";
                activeMemberCount++;
              }
            }
          }
                    cartridge.setActiveInstances(activeMemberCount);
          cartridge.setStatus(cartridgeStatus);

                    // Ignoring the LB cartridges since they are not shown to the user.
                    if(cartridge.isLoadBalancer())
                        continue;
                    cartridges.add(cartridge);
                }
            } else {
                if (log.isDebugEnabled()) {
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

    }

   
    static Cartridge getSubscription(String cartridgeAlias, ConfigurationContext configurationContext) throws RestAPIException {
     
      Cartridge cartridge =  getCartridgeFromSubscription(cartridgeSubsciptionManager.getCartridgeSubscription(ApplicationManagementUtil.
                    getTenantId(configurationContext), cartridgeAlias));
     
      if (cartridge == null) {
        String message = "Unregistered [alias]: "+cartridgeAlias+"! Please enter a valid alias.";
        log.error(message);
      throw new RestAPIException(Response.Status.NOT_FOUND, message);
      }
        Cluster cluster = TopologyClusterInformationModel.getInstance().getCluster(ApplicationManagementUtil.getTenantId(configurationContext)
                ,cartridge.getCartridgeType(), cartridge.getCartridgeAlias());
        String cartridgeStatus = "Inactive";
        int activeMemberCount = 0;

        // cluster might not be created yet, so need to check
        if (cluster != null) {
            Collection<Member> members = cluster.getMembers();
            if (members != null ) {
                for (Member member : members) {
                    if(member.isActive()) {
                        cartridgeStatus = "Active";
                        activeMemberCount++;
                    }
                }
            }
        }

        cartridge.setActiveInstances(activeMemberCount);
    cartridge.setStatus(cartridgeStatus);
    return cartridge;
     
    }
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

    if (subscription == null) {
      return null;
    }
    try {
      Cartridge cartridge = new Cartridge();
      cartridge.setCartridgeType(subscription.getCartridgeInfo()
          .getType());
      cartridge.setMultiTenant(subscription.getCartridgeInfo()
          .getMultiTenant());
      cartridge
          .setProvider(subscription.getCartridgeInfo().getProvider());
      cartridge.setVersion(subscription.getCartridgeInfo().getVersion());
      cartridge.setDescription(subscription.getCartridgeInfo()
          .getDescription());
      cartridge.setDisplayName(subscription.getCartridgeInfo()
          .getDisplayName());
      cartridge.setCartridgeAlias(subscription.getAlias());
      cartridge.setHostName(subscription.getHostName());
      cartridge.setMappedDomain(subscription.getMappedDomain());
      if (subscription.getRepository() != null) {
        cartridge.setRepoURL(subscription.getRepository().getUrl());
      }

      if (subscription instanceof DataCartridgeSubscription) {
        DataCartridgeSubscription dataCartridgeSubscription = (DataCartridgeSubscription) subscription;
        cartridge.setDbHost(dataCartridgeSubscription.getDBHost());
        cartridge.setDbUserName(dataCartridgeSubscription
            .getDBUsername());
        cartridge
            .setPassword(dataCartridgeSubscription.getDBPassword());
      }

      if (subscription.getLbClusterId() != null
          && !subscription.getLbClusterId().isEmpty()) {
        cartridge.setLbClusterId(subscription.getLbClusterId());
      }

      cartridge.setStatus(subscription.getSubscriptionStatus());
      cartridge.setPortMappings(subscription.getCartridgeInfo()
          .getPortMappings());

            if(subscription.getCartridgeInfo().getLbConfig() != null && subscription.getCartridgeInfo().getProperties() != null) {
                for(Property property: subscription.getCartridgeInfo().getProperties()) {
                    if(property.getName().equals("load.balancer")) {
                        cartridge.setLoadBalancer(true);
                    }
                }
            }
     
      return cartridge;
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

    }


    public StratosAdminResponse addCartirdgeDefinition(CartridgeDefinitionBean cartridgeDefinitionBean){
        this.cartridgeDefinitionBeanList.add(cartridgeDefinitionBean);
        Cartridge cartridge = new Cartridge();
        cartridge.setCartridgeType(cartridgeDefinitionBean.type);
        cartridge.setDescription(cartridgeDefinitionBean.description);
        cartridge.setDisplayName(cartridgeDefinitionBean.displayName);
        cartridge.setMultiTenant(cartridgeDefinitionBean.multiTenant);
        cartridge.setProvider(cartridgeDefinitionBean.provider);
        cartridge.setVersion(cartridgeDefinitionBean.version);

        if(cartridge.isMultiTenant()){
            availableMultiTenantCartridges.put(cartridge.getCartridgeType(), cartridge);
        }else{
            availableSingleTenantCartridges.put(cartridge.getCartridgeType(), cartridge);
        }
        System.out.println(availableMultiTenantCartridges.size());
        System.out.println(availableSingleTenantCartridges.size());
        StratosAdminResponse stratosAdminResponse = new StratosAdminResponse();
        stratosAdminResponse.setMessage("Successfully deployed deployment policy definition with type ");
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

    }

    public SubscriptionInfo subscribeToCartridge(CartridgeInfoBean cartridgeInfoBean) throws RestAPIException{
         String cartridgeType = cartridgeInfoBean.getCartridgeType();
         String alias = cartridgeInfoBean.getAlias();
         Cartridge subscribedCartridge;
         // retrieve the cartridge from available ones
         if(availableSingleTenantCartridges.containsKey(cartridgeType)){
            subscribedCartridge = availableSingleTenantCartridges.get(cartridgeType);

         }else if(availableMultiTenantCartridges.containsKey(cartridgeType)){
             subscribedCartridge = availableMultiTenantCartridges.get(cartridgeType);
         }else {
             String msg = "Wrong programme sequence";
             throw new RestAPIException(msg);
         }
        //Proper way is copy construrctor
        Cartridge copy = new Cartridge();
        copy.setCartridgeType(subscribedCartridge.getCartridgeType());
        copy.setDescription(subscribedCartridge.getDescription());
        copy.setDisplayName(subscribedCartridge.getDisplayName());
        copy.setMultiTenant(subscribedCartridge.isMultiTenant());
        copy.setProvider(subscribedCartridge.getProvider());
        copy.setVersion(subscribedCartridge.getVersion());
        copy.setCartridgeAlias(alias);
        copy.setHostName("dummy.stratos.com");
        copy.setRepoURL("http://dummy.stratos.com/myrepo.git");

        subscribedCartridges.put(alias,copy);

        SubscriptionInfo subscriptionInfo = new SubscriptionInfo();
        subscriptionInfo.setHostname(copy.getHostName());
        subscriptionInfo.setRepositoryURL(copy.getRepoURL());

        return subscriptionInfo;
    }
View Full Code Here

Examples of org.apache.stratos.manager.dto.Cartridge

        if (repoURL != null) {
          System.out.println("GIT Repository URL: " + repoURL);
        }

        Cartridge cart = stub.getCartridgeInfo(alias);
        System.out.format("Your application is being published here. %s%n", getAccessURLs(cart));
      }
      if (subcriptionConnectInfo != null) {
        hostnames += ", " + subcriptionConnectInfo.getHostname();
        hostnamesLabel = "host names";

        Cartridge cart = stub.getCartridgeInfo(alias);
        System.out.format("Your data application is being published here. %s%n", getAccessURLs(cart));
      }
      if (externalRepoURL != null) {
        String takeTimeMsg = "(this might take few minutes... depending on repo size)\n";
        System.out.println(takeTimeMsg);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.