JarCastingjava-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));
}