[ADD] PipelineService 미구현

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;
+//}

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;
+//}

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;
+//}

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<V2Beta1Pipeline> request = new HttpEntity<>(pipeline, headers);
+//
+//        ResponseEntity<V2Beta1Pipeline> 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<V2Beta1CreatePipelineAndVersionRequest> request = new HttpEntity<>(requestPayload, headers);
+//
+//        ResponseEntity<V2Beta1Pipeline> response = restTemplate.exchange(
+//                kubeflowApiUrl + "/apis/v2beta1/pipelines/create",
+//                HttpMethod.POST,
+//                request,
+//                V2Beta1Pipeline.class
+//        );
+//        return response.getBody();
+//    }
+//}