Examples of ClusterConfig


Examples of com.sun.appserv.management.config.ClusterConfig

   */
  static public DeployedItemRefConfig getDeployedItemRefObject(String name, String target){
      StandaloneServerConfig server = AMXUtil.getDomainConfig().getStandaloneServerConfigMap().get(target);
      DeployedItemRefConfig ref = null;
            if (server == null){
    ClusterConfig cluster = AMXUtil.getDomainConfig().getClusterConfigMap().get(target);
    ref = (cluster == null) ? null :  cluster.getDeployedItemRefConfigMap().get(name);
      }else{
    ref = server.getDeployedItemRefConfigMap().get(name);
      }
      return ref;
  }
View Full Code Here

Examples of com.sun.appserv.management.config.ClusterConfig

   */
  static public List<DeployedItemRefConfig> getAllDeployedItemRefObject(String appName, String target){
            List<DeployedItemRefConfig> result = new ArrayList();
      StandaloneServerConfig server = AMXUtil.getDomainConfig().getStandaloneServerConfigMap().get(target);
            if (server == null){
    ClusterConfig cluster = AMXUtil.getDomainConfig().getClusterConfigMap().get(target);
                if (cluster == null)
                    return result;
    result.add( cluster.getDeployedItemRefConfigMap().get(appName));
                Map<String,ClusteredServerConfig> serverMap = AMXUtil.getDomainConfig().getClusterConfigMap().get(target).getClusteredServerConfigMap();
                for(String instanceName : serverMap.keySet()){
                    result.add (serverMap.get(instanceName).getDeployedItemRefConfigMap().get(appName));
                }
      }else{
View Full Code Here

Examples of com.sun.appserv.management.config.ClusterConfig

            StandaloneServerConfig server = AMXUtil.getDomainConfig().getStandaloneServerConfigMap().get(target);
            refs = server.getDeployedItemRefConfigMap().values();
            Map lbMap = AMXUtil.getLBConfigHelper().getLoadBalancers(target, false);
            handlerContext.setOutputValue("hasLB", !lbMap.isEmpty());
        } else {
            ClusterConfig cluster = AMXUtil.getDomainConfig().getClusterConfigMap().get(target);
            refs = cluster.getDeployedItemRefConfigMap().values();
            Map lbMap = AMXUtil.getLBConfigHelper().getLoadBalancers(target, true);
            handlerContext.setOutputValue("hasLB", !lbMap.isEmpty());
        }

        HashMap<String, HashMap> sipModules = getSipModulesInfo();
View Full Code Here

Examples of com.sun.appserv.management.config.ClusterConfig

       
        if (isServer){
            StandaloneServerConfig server = AMXUtil.getDomainConfig().getStandaloneServerConfigMap().get(target);
            refs = server.getResourceRefConfigMap().values();
        }else{
            ClusterConfig cluster = AMXUtil.getDomainConfig().getClusterConfigMap().get(target);
            refs = cluster.getResourceRefConfigMap().values();
        }
       
        for(ResourceRefConfig refObject : refs){
            String resName = refObject.getName();
            String resType = getResourceType(resName);
View Full Code Here

Examples of com.sun.appserv.management.config.ClusterConfig

   
    /* returns the status image for the cluster.  The image will show running as long as there
     * is one instance running in that cluster.
     */
    private static String getClusterStatus(String clusterName){
        ClusterConfig cluster = AMXUtil.getDomainConfig().getClusterConfigMap().get(clusterName);
        if (cluster == null) return "";
        Map<String,ClusteredServerConfig> serverMap = cluster.getClusteredServerConfigMap();
        if (serverMap.size() == 0) return "";
        for(String instance : serverMap.keySet()){
            J2EEServer j2eeServer = AMXUtil.getJ2EEDomain().getJ2EEServerMap().get(instance);
            if(j2eeServer != null){
                int state = j2eeServer.getstate();
View Full Code Here

Examples of net.kuujo.copycat.cluster.ClusterConfig

  }

  public void testCompactEndOfLog() throws Exception {
    appendEntries();
    log.compact(5,
      new SnapshotEntry(1, new ClusterConfig()
        .withLocalMember(new Member("foo"))
        .withRemoteMembers(new Member("bar"), new Member("baz")), "Hello world!".getBytes()));

    assertEquals(log.firstIndex(), 5);
    assertEquals(log.lastIndex(), 5);
View Full Code Here

Examples of org.apache.hadoop.chukwa.hicc.ClusterConfig

      try
      {
        String dateclause = timeField + " >= '" + startS
          + "' and " + timeField + " <= '" + endS + "'";
       
           ClusterConfig cc = new ClusterConfig();
           String jdbc = cc.getURL(cluster);
          
         Connection conn = DriverManager.getConnection(jdbc);
        
         stmt = conn.createStatement();
         String query = "";
View Full Code Here

Examples of org.apache.hadoop.chukwa.util.ClusterConfig

        }
      }
    }
    log.debug("cluster name:" + cluster);
    if (!cluster.equals("")) {
      ClusterConfig cc = new ClusterConfig();
      jdbc_url = cc.getURL(cluster);
    }
    try {
      DatabaseWriter dbWriter = new DatabaseWriter(cluster);
      conn = dbWriter.getConnection();
    } catch(Exception ex) {
View Full Code Here

Examples of org.apache.helix.api.config.ClusterConfig

    // add a transition constraint (with a resource scope)
    clusterBuilder.addTransitionConstraint(Scope.resource(resource.getId()), lockUnlock.getStateModelDefId(),
        Transition.from(State.from("RELEASED"), State.from("LOCKED")), 1);

    ClusterConfig cluster = clusterBuilder.build();

    // set up a connection to work with ZooKeeper-persisted data
    HelixConnection connection = new ZkHelixConnection(args[0]);
    connection.connect();
View Full Code Here

Examples of org.apache.helix.api.config.ClusterConfig

  private boolean createCluster(ClusterId clusterId, ClusterAccessor accessor, String modifierName,
      int modifierValue) {
    // create a cluster
    UserConfig userConfig = new UserConfig(Scope.cluster(clusterId));
    userConfig.setIntField(modifierName, modifierValue);
    ClusterConfig cluster = new ClusterConfig.Builder(clusterId).userConfig(userConfig).build();
    return accessor.createCluster(cluster);
  }
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.