Commit 2e5c644b authored by liugaoling's avatar liugaoling

add cancel job

parent 5b06e4b7
...@@ -12,10 +12,10 @@ public interface CloudamURL { ...@@ -12,10 +12,10 @@ public interface CloudamURL {
String CREATE_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job"; String CREATE_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job";
String GET_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job/request"; String GET_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job/workflow";
String STOP_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job"; String STOP_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job";
String DELETE_JOB_URL_SUFFIX = ""; String CANCEL_JOB_URL_SUFFIX = "c3ce/cloud-bursting/job/workflow";
} }
package com.cloudam.cromwell.core;
import com.cloudam.cromwell.CloudamRequest;
import com.cloudam.cromwell.constant.CloudamURL;
import okhttp3.Request;
public class CancelJobRequest extends CloudamRequest<GetJobResponse> {
private final String urlSuffix = CloudamURL.CANCEL_JOB_URL_SUFFIX;
private String jobId;
public String getJobId() {
return jobId;
}
public void setJobId(String jobId) {
this.jobId = jobId;
}
@Override
public Class<GetJobResponse> getResponseClass() {
return GetJobResponse.class;
}
@Override
public Request.Builder getBuilder(Request.Builder builder, String url, CloudamRequest<GetJobResponse> cloudamRequest) {
CancelJobRequest cancelJobRequest = (CancelJobRequest) cloudamRequest;
return builder
.url(url + cancelJobRequest.urlSuffix + "?requestId=" + cancelJobRequest.getJobId())
.delete();
}
}
package com.cloudam.cromwell.core;
import com.cloudam.cromwell.CloudamResponse;
public class CancelJobResponse extends CloudamResponse {
}
...@@ -9,7 +9,6 @@ public class GetJobRequest extends CloudamRequest<GetJobResponse> { ...@@ -9,7 +9,6 @@ public class GetJobRequest extends CloudamRequest<GetJobResponse> {
private final String urlSuffix = CloudamURL.GET_JOB_URL_SUFFIX; private final String urlSuffix = CloudamURL.GET_JOB_URL_SUFFIX;
private String jobId; private String jobId;
private String masterId;
public String getJobId() { public String getJobId() {
return jobId; return jobId;
...@@ -19,14 +18,6 @@ public class GetJobRequest extends CloudamRequest<GetJobResponse> { ...@@ -19,14 +18,6 @@ public class GetJobRequest extends CloudamRequest<GetJobResponse> {
this.jobId = jobId; this.jobId = jobId;
} }
public String getMasterId() {
return masterId;
}
public void setMasterId(String masterId) {
this.masterId = masterId;
}
@Override @Override
public Class<GetJobResponse> getResponseClass() { public Class<GetJobResponse> getResponseClass() {
return GetJobResponse.class; return GetJobResponse.class;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment