Examples of ResourceJobManager

org.apache.aiaravata.application.catalog.data.model.ResourceJobManager
org.apache.airavata.model.appcatalog.ResourceJobManager
org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager
Resource Job Manager Information resourceJobManagerType: A typical HPC cluster has a single Job Manager to manage the resources. pushMonitoringEndpoint: If the job manager pushes out state changes to a database or bus, specify the service endpoint. Ex: Moab Web Service, Moab MongoDB URL, AMQP (GLUE2) Broker jobManagerBinPath: Path to the Job Manager Installation Binary directory. jobManagerCommands: An enumeration of commonly used manager commands.

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

  public static ResourceJobManager createResourceJobManager(
      ResourceJobManagerType resourceJobManagerType,
      String jobManagerBinPath,
      Map<JobManagerCommand, String> jobManagerCommands,
      String pushMonitoringEndpoint) {
    ResourceJobManager resourceJobManager=new ResourceJobManager();;
    resourceJobManager.setResourceJobManagerType(resourceJobManagerType);
    resourceJobManager.setJobManagerBinPath(jobManagerBinPath);
    resourceJobManager.setJobManagerCommands(jobManagerCommands);
    resourceJobManager.setPushMonitoringEndpoint(pushMonitoringEndpoint);
    return resourceJobManager;
  }

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

                "localhost", new HashSet<String>(Arrays.asList(new String[]{"127.0.0.1"})), new HashSet<String>(Arrays.asList(new String[]{"127.0.0.1"})));
//      host.setIsEmpty(true);
        host.setComputeResourceId(client.registerComputeResource(host));


        LOCALSubmission localSubmission = new LOCALSubmission();
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.FORK, null, null, null);
        localSubmission.setResourceJobManager(resourceJobManager);
        client.addLocalSubmissionDetails(host.getComputeResourceId(), 1, localSubmission);


        LOCALDataMovement localDataMovement = new LOCALDataMovement();
        client.addLocalDataMovementDetails(host.getComputeResourceId(), 1, localDataMovement);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager




        SSHJobSubmission jobSubmission = new SSHJobSubmission();
        jobSubmission.setSshPort(22);
        jobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.FORK, null, null, null);
        jobSubmission.setResourceJobManager(resourceJobManager);
        client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, jobSubmission);


        SCPDataMovement scpDataMovement = new SCPDataMovement();
        scpDataMovement.setSecurityProtocol(SecurityProtocol.SSH_KEYS);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        host.addToIpAddresses(trestleshpcHostAddress);
        host.addToHostAliases(trestleshpcHostAddress);
        host.setComputeResourceId(client.registerComputeResource(host));


        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.PBS, "/opt/torque/bin/", null, null);
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
        sshJobSubmission.setSshPort(22);
        client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        host.addToIpAddresses(trestleshpcHostAddress);
        host.addToHostAliases(trestleshpcHostAddress);
        host.setComputeResourceId(client.registerComputeResource(host));


        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.PBS, "/opt/torque/bin/", null, null);
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
        sshJobSubmission.setSshPort(22);
        client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(stampedeHostAddress, null, null);
        host.addToHostAliases(stampedeHostAddress);
        host.addToIpAddresses(stampedeHostAddress);
        host.setComputeResourceId(client.registerComputeResource(host));


        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.SLURM, "/usr/bin/", null, "push");
        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
        sshJobSubmission.setSshPort(2222);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(stampedeHostAddress, null, null);
        host.addToHostAliases(stampedeHostAddress);
        host.addToIpAddresses(stampedeHostAddress);
        host.setComputeResourceId(client.registerComputeResource(host));


        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.SLURM, "/usr/bin/", null, "push");
        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
        sshJobSubmission.setSshPort(2222);
        client.addSSHJobSubmissionDetails(host.getComputeResourceId(), 1, sshJobSubmission);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        ComputeResourceDescription host = DocumentCreatorUtils.createComputeResourceDescription(lonestarHostAddress, null, null);
        host.addToHostAliases(lonestarHostAddress);
        host.addToIpAddresses(lonestarHostAddress);
        host.setComputeResourceId(client.registerComputeResource(host));


        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/sge6.2/bin/lx24-amd64/", null, null);
        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.GSI);
        sshJobSubmission.setSshPort(22);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        host.setComputeResourceId(client.registerComputeResource(host));




        Map<JobManagerCommand, String> commands = new HashMap<JobManagerCommand, String>();
        commands.put(JobManagerCommand.SUBMISSION, "aprun -n 1");
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/torque/torque-4.2.3.1/bin/", commands, null);
        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
        sshJobSubmission.setSshPort(22);

View Full Code Here

Examples of org.apache.airavata.model.appcatalog.computeresource.ResourceJobManager

        host.setComputeResourceId(client.registerComputeResource(host));




        Map<JobManagerCommand, String> commands = new HashMap<JobManagerCommand, String>();
        commands.put(JobManagerCommand.SUBMISSION, "aprun -n 4");
        ResourceJobManager resourceJobManager = DocumentCreatorUtils.createResourceJobManager(ResourceJobManagerType.UGE, "/opt/torque/torque-4.2.3.1/bin/", commands, null);
        SSHJobSubmission sshJobSubmission = new SSHJobSubmission();
        sshJobSubmission.setResourceJobManager(resourceJobManager);
        sshJobSubmission.setSecurityProtocol(SecurityProtocol.SSH_KEYS);
        sshJobSubmission.setSshPort(22);

View Full Code Here

0 1 2

TOP

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.