whirr-49 options for cluster controller

gistfile1.java

  public Map<? extends NodeMetadata, ExecResponse> runScriptOnNodesMatching(ClusterSpec spec,
        Predicate<NodeMetadata> condition, Statement statement) throws IOException, RunScriptOnNodesException {
    return runScriptOnNodesMatching(spec, condition, statement, null);
  }
  public Map<? extends NodeMetadata, ExecResponse> runScriptOnNodesMatching(ClusterSpec spec,
      Predicate<NodeMetadata> condition, Statement statement, RunScriptOptions options) 
      throws IOException, RunScriptOnNodesException {

    Credentials credentials = new Credentials(spec.getClusterUser(), spec.getPrivateKey());
    if (options==null) 
      options = overrideCredentialsWith(credentials).wrapInInitScript(false).runAsRoot(false);
    else if (options.getOverridingCredentials()==null)
      options = options.overrideCredentialsWith(credentials);

    condition = Predicates.and(runningInGroup(spec.getClusterName()), condition);
    
    ComputeServiceContext context = getCompute().apply(spec);
    return context.getComputeService().runScriptOnNodesMatching(condition, statement, options);
  }