java-mesos-client

Mesos client for chronos and marathon job management

Install

Add the following dependency to your pom file:

<dependency>
    <groupId>com.github.chen0040</groupId>
    <artifactId>java-mesos-client</artifactId>
    <version>1.0.1</version>
</dependency>

Usage

Working with Mesos Master

Read states from mesos master:

import com.github.chen0040.mesos.client.core.MesosUtil;

String mesosMasterUrl1 = "http://10.0.0.15:5050";
String json1 =MesosUtil.getStateJson(mesosMasterUrl1);
System.out.println(json1);

Read tasks from mesos master:

import com.github.chen0040.mesos.client.core.MesosUtil;

String mesosMasterUrl1 = "http://10.0.0.15:5050";
String json1 = MesosUtil.getTasks("http://10.0.0.15:5050");
System.out.println(json1);

Working with Chronos

To list jobs in Chronos

String chronosUrl = "http://10.0.0.1:4400";
List<ChronosJobInfo> result = ChronosUtil.listJobs(chronosUrl);

result.stream().forEach(job -> {
 System.out.println("name: " + job.getName());
 System.out.println("command: " + job.getCommand());
});

To get a particular job in Chronos:

String chronosUrl = "http://10.0.0.1:4400";
List<ChronosJobInfo> result = ChronosUtil.listJobs(chronosUrl);

if (!result.isEmpty()) {
 String appId = result.get(0).getName();

 Optional<ChronosJobInfo> jobInfo = ChronosUtil.getJob(chronosUrl, appId);

 System.out.println(JSON.toJSONString(jobInfo.orElseGet(ChronosJobInfo::new)));

 Assert.assertEquals(appId, jobInfo.get().getName());
}

To start a particular job in Chronos:

String chronosUrl = "http://10.0.0.1:4400";
String regressionTestId = "regtest";
String regressionTestCmd = "echo 'Hello Chronos' ; sleep 5";

 if (!ChronosUtil.jobExists(chronosUrl, regressionTestId)) {
 ChronosJobRequest request = new ChronosJobRequest("PT15M");
 request.setCommand(regressionTestCmd);
 request.setName(regressionTestId);
 request.setCpus(0.1);
 request.setMem(100);

 System.out.println(ChronosUtil.startJob(chronosUrl, request));

 try {
    Thread.sleep(5000l);
 }
 catch (InterruptedException e) {
    e.printStackTrace();
 }

 Assert.assertTrue(ChronosUtil.jobExists(chronosUrl, regressionTestId));
}

To kill a particular job in Chronos:

String chronosUrl = "http://10.0.0.1:4400";
String regressionTestId = "regtest";
if (ChronosUtil.jobExists(chronosUrl, regressionTestId)) {
 System.out.println(ChronosUtil.killJob(chronosUrl, regressionTestId));

 try {
    Thread.sleep(5000l);
 }
 catch (InterruptedException e) {
    e.printStackTrace();
 }

 Assert.assertFalse(ChronosUtil.jobExists(chronosUrl, regressionTestId));
}

Marathon

To list jobs in Marathon:

String marathonUrl = "http://10.0.0.2:8080";
MarathonJobInfoList result = MarathonUtil.listJobs(marathonUrl);

result.getApps().stream().forEach(job -> {
 System.out.println("id: " + job.getId());
 System.out.println("cmd: " + job.getCmd());
});

To get a particular job in Marathon:

String marathonUrl = "http://10.0.0.2:8080";
MarathonJobInfoList result = MarathonUtil.listJobs(marathonUrl);

if (!result.getApps().isEmpty()) {
 String appId = result.getApps().get(0).getId();

 MarathonJobInfoList jobInfo = MarathonUtil.listJobs(marathonUrl, appId);

 System.out.println(JSON.toJSONString(jobInfo));

 Assert.assertEquals(appId, jobInfo.getApps().get(0).getId());
}

To start a particular job in Marathon:

String marathonUrl = "http://10.0.0.2:8080";
String regressionTestCmd = "while [ true ] ; do echo 'Hello Marathon' ; sleep 5 ; done";
String regressionTestId = "regtest";
   
if (!MarathonUtil.jobExists(marathonUrl, regressionTestId)) {
 MarathonJobRequest request = new MarathonJobRequest();
 request.setCmd(regressionTestCmd);
 request.setId(regressionTestId);
 System.out.println(MarathonUtil.startJob(marathonUrl, request));

 try {
    Thread.sleep(5000l);
 }
 catch (InterruptedException e) {
    e.printStackTrace();
 }

 Assert.assertTrue(MarathonUtil.jobExists(marathonUrl, regressionTestId));
}

To kill a particular job in Marathon:

String marathonUrl = "http://10.0.0.2:8080";
String regressionTestId = "regtest";

if (MarathonUtil.jobExists(marathonUrl, regressionTestId)) {
 System.out.println(MarathonUtil.killJob(marathonUrl, regressionTestId));

 try {
    Thread.sleep(5000l);
 }
 catch (InterruptedException e) {
    e.printStackTrace();
 }

 Assert.assertFalse(MarathonUtil.jobExists(marathonUrl, regressionTestId));
}