diff --git a/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1CreatePipelineAndVersionRequest.java b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1CreatePipelineAndVersionRequest.java new file mode 100644 index 0000000..4e2dda6 --- /dev/null +++ b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1CreatePipelineAndVersionRequest.java @@ -0,0 +1,9 @@ +//package kr.re.etri.autoflow.payload.request; +// +//import lombok.Data; +// +//@Data +//public class V2Beta1CreatePipelineAndVersionRequest { +// private V2Beta1Pipeline pipeline; +// private V2Beta1PipelineVersion pipeline_version; +//} diff --git a/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1Pipeline.java b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1Pipeline.java new file mode 100644 index 0000000..271c2f6 --- /dev/null +++ b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1Pipeline.java @@ -0,0 +1,12 @@ +//package kr.re.etri.autoflow.payload.request; +// +//import lombok.Data; +// +//@Data +//public class V2Beta1Pipeline { +// private String pipeline_id; +// private String display_name; +// private String name; +// private String description; +// private String namespace; +//} \ No newline at end of file diff --git a/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1PipelineVersion.java b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1PipelineVersion.java new file mode 100644 index 0000000..873ee72 --- /dev/null +++ b/src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1PipelineVersion.java @@ -0,0 +1,14 @@ +//package kr.re.etri.autoflow.payload.request; +// +//import lombok.Data; +// +//@Data +//public class V2Beta1PipelineVersion { +// private String pipeline_id; +// private String pipeline_version_id; +// private String display_name; +// private String name; +// private String description; +// private String package_url; +// private String code_source_url; +//} \ No newline at end of file diff --git a/src/main/java/kr/re/etri/autoflow/service/PipelineService.java b/src/main/java/kr/re/etri/autoflow/service/PipelineService.java new file mode 100644 index 0000000..3ea9742 --- /dev/null +++ b/src/main/java/kr/re/etri/autoflow/service/PipelineService.java @@ -0,0 +1,49 @@ +//package kr.re.etri.autoflow.service; +// +//import kr.re.etri.autoflow.payload.request.V2Beta1CreatePipelineAndVersionRequest; +//import kr.re.etri.autoflow.payload.request.V2Beta1Pipeline; +//import lombok.RequiredArgsConstructor; +//import org.springframework.beans.factory.annotation.Value; +//import org.springframework.http.*; +//import org.springframework.stereotype.Service; +//import org.springframework.web.client.RestTemplate; +// +//@Service +//@RequiredArgsConstructor +//public class PipelineService { +// +// private final RestTemplate restTemplate; +// +// @Value("${kubeflow.api.url}") +// private String kubeflowApiUrl; +// +// public V2Beta1Pipeline createPipeline(V2Beta1Pipeline pipeline) { +// HttpHeaders headers = new HttpHeaders(); +// headers.setContentType(MediaType.APPLICATION_JSON); +// +// HttpEntity request = new HttpEntity<>(pipeline, headers); +// +// ResponseEntity response = restTemplate.exchange( +// kubeflowApiUrl + "/apis/v2beta1/pipelines", +// HttpMethod.POST, +// request, +// V2Beta1Pipeline.class +// ); +// return response.getBody(); +// } +// +// public V2Beta1Pipeline createPipelineAndVersion(V2Beta1CreatePipelineAndVersionRequest requestPayload) { +// HttpHeaders headers = new HttpHeaders(); +// headers.setContentType(MediaType.APPLICATION_JSON); +// +// HttpEntity request = new HttpEntity<>(requestPayload, headers); +// +// ResponseEntity response = restTemplate.exchange( +// kubeflowApiUrl + "/apis/v2beta1/pipelines/create", +// HttpMethod.POST, +// request, +// V2Beta1Pipeline.class +// ); +// return response.getBody(); +// } +//}