From 52e56ed75227eba5e7cee58b363b77490bf4007a Mon Sep 17 00:00:00 2001 From: bjkim Date: Fri, 19 Sep 2025 10:07:15 +0900 Subject: [PATCH] =?UTF-8?q?[ADD]=20PipelineService=20=EB=AF=B8=EA=B5=AC?= =?UTF-8?q?=ED=98=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...2Beta1CreatePipelineAndVersionRequest.java | 9 ++++ .../payload/request/V2Beta1Pipeline.java | 12 +++++ .../request/V2Beta1PipelineVersion.java | 14 ++++++ .../autoflow/service/PipelineService.java | 49 +++++++++++++++++++ 4 files changed, 84 insertions(+) create mode 100644 src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1CreatePipelineAndVersionRequest.java create mode 100644 src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1Pipeline.java create mode 100644 src/main/java/kr/re/etri/autoflow/payload/request/V2Beta1PipelineVersion.java create mode 100644 src/main/java/kr/re/etri/autoflow/service/PipelineService.java 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(); +// } +//}