Package org.apache.whirr.actions

Examples of org.apache.whirr.actions.ByonClusterAction.execute()

74
75
76
77
78
79
80
81
82
83
84
    stopServices(clusterSpec); // for BYON only
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction destroyer = new ByonClusterAction(DESTROY_ACTION,
        getCompute(), handlerMap);
    destroyer.execute(clusterSpec, null);
  }
 
  /**
   * Provisions the hardware for a BYON cluster.
   */
 
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
      InterruptedException {
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction bootstrapper = new ByonClusterAction(BOOTSTRAP_ACTION,
        getCompute(), handlerMap);
    Cluster cluster = bootstrapper.execute(clusterSpec, null);
    getClusterStateStore(clusterSpec).save(cluster);
    return cluster;
  }

  /**
 
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
      throws IOException, InterruptedException {
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction configurer = new ByonClusterAction(CONFIGURE_ACTION,
        getCompute(), handlerMap);
    cluster = configurer.execute(clusterSpec, cluster);
    getClusterStateStore(clusterSpec).save(cluster);
    return cluster;
  }
 
  public Map<? extends NodeMetadata, ExecResponse> runScriptOnNodesMatching(final ClusterSpec spec,
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    stopServices(clusterSpec); // for BYON only
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction destroyer = new ByonClusterAction(DESTROY_ACTION,
        getCompute(), handlerMap);
    destroyer.execute(clusterSpec, null);
  }
 
  /**
   * Provisions the hardware for a BYON cluster.
   */
 
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
      InterruptedException {
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction bootstrapper = new ByonClusterAction(BOOTSTRAP_ACTION,
        getCompute(), handlerMap);
    Cluster cluster = bootstrapper.execute(clusterSpec, null);
    getClusterStateStore(clusterSpec).save(cluster);
    return cluster;
  }

  /**
 
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
      throws IOException, InterruptedException {
    LoadingCache<String, ClusterActionHandler> handlerMap = handlerMapFactory
        .create();
    ClusterAction configurer = new ByonClusterAction(CONFIGURE_ACTION,
        getCompute(), handlerMap);
    cluster = configurer.execute(clusterSpec, cluster);
    getClusterStateStore(clusterSpec).save(cluster);
    return cluster;
  }
 
  public Map<? extends NodeMetadata, ExecResponse> runScriptOnNodesMatching(final ClusterSpec spec,
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
    Map<String, ClusterActionHandler> handlerMap = new HandlerMapFactory()
        .create();

    ClusterAction bootstrapper = new ByonClusterAction(BOOTSTRAP_ACTION, getCompute(), handlerMap);
    Cluster cluster = bootstrapper.execute(clusterSpec, null);

    ClusterAction configurer = new ByonClusterAction(CONFIGURE_ACTION, getCompute(), handlerMap);
    cluster = configurer.execute(clusterSpec, cluster);

    return cluster;
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
    ClusterAction bootstrapper = new ByonClusterAction(BOOTSTRAP_ACTION, getCompute(), handlerMap);
    Cluster cluster = bootstrapper.execute(clusterSpec, null);

    ClusterAction configurer = new ByonClusterAction(CONFIGURE_ACTION, getCompute(), handlerMap);
    cluster = configurer.execute(clusterSpec, cluster);

    return cluster;
  }

  public void destroyCluster(ClusterSpec clusterSpec) throws IOException,
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
      InterruptedException {
    Map<String, ClusterActionHandler> handlerMap = new HandlerMapFactory()
        .create();

    ClusterAction destroyer = new ByonClusterAction(DESTROY_ACTION, getCompute(), handlerMap);
    destroyer.execute(clusterSpec, null);
  }
 
  @Override
  public void destroyInstance(ClusterSpec clusterSpec, String instanceId)
      throws IOException {
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
    Map<String, ClusterActionHandler> handlerMap = new HandlerMapFactory()
        .create();

    ClusterAction bootstrapper = new ByonClusterAction(BOOTSTRAP_ACTION, getCompute(), handlerMap);
    Cluster cluster = bootstrapper.execute(clusterSpec, null);

    ClusterAction configurer = new ByonClusterAction(CONFIGURE_ACTION, getCompute(), handlerMap);
    cluster = configurer.execute(clusterSpec, cluster);

    getClusterStateStore(clusterSpec).save(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.