-
Notifications
You must be signed in to change notification settings - Fork 61
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix cloudProvider not supply correct
- Loading branch information
Showing
10 changed files
with
109 additions
and
49 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
71 changes: 71 additions & 0 deletions
71
...rc/main/java/com/oceanbase/odc/service/task/resource/DefaultNativeK8sOperatorBuilder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,71 @@ | ||
| /* | ||
| * Copyright (c) 2023 OceanBase. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
| package com.oceanbase.odc.service.task.resource; | ||
|
|
||
| import java.io.IOException; | ||
|
|
||
| import org.apache.commons.lang3.StringUtils; | ||
|
|
||
| import com.oceanbase.odc.metadb.resource.ResourceRepository; | ||
| import com.oceanbase.odc.service.task.config.K8sProperties; | ||
| import com.oceanbase.odc.service.task.config.TaskFrameworkProperties; | ||
| import com.oceanbase.odc.service.task.dummy.LocalMockK8sJobClient; | ||
| import com.oceanbase.odc.service.task.resource.client.DefaultK8sJobClientSelector; | ||
| import com.oceanbase.odc.service.task.resource.client.K8sJobClientSelector; | ||
| import com.oceanbase.odc.service.task.resource.client.NativeK8sJobClient; | ||
| import com.oceanbase.odc.service.task.resource.client.NullK8sJobClientSelector; | ||
|
|
||
| import lombok.extern.slf4j.Slf4j; | ||
|
|
||
| /** | ||
| * native k8s operator | ||
| * | ||
| * @author longpeng.zlp | ||
| * @date 2025/1/22 13:57 | ||
| */ | ||
| @Slf4j | ||
| public class DefaultNativeK8sOperatorBuilder extends AbstractK8sResourceOperatorBuilder { | ||
| public static final String NATIVE_K8S_POD_TYPE = "nativeK8sPod"; | ||
|
|
||
| public DefaultNativeK8sOperatorBuilder(TaskFrameworkProperties taskFrameworkProperties, | ||
| ResourceRepository resourceRepository) throws IOException { | ||
| super(taskFrameworkProperties, resourceRepository, NATIVE_K8S_POD_TYPE); | ||
| } | ||
|
|
||
| /** | ||
| * build k8s job selector | ||
| */ | ||
| protected K8sJobClientSelector buildK8sJobSelector( | ||
| TaskFrameworkProperties taskFrameworkProperties) throws IOException { | ||
| K8sProperties k8sProperties = taskFrameworkProperties.getK8sProperties(); | ||
| K8sJobClientSelector k8sJobClientSelector; | ||
| if (taskFrameworkProperties.isEnableK8sLocalDebugMode()) { | ||
| // k8s use in local debug mode | ||
| log.info("local debug k8s cluster enabled."); | ||
| k8sJobClientSelector = new LocalMockK8sJobClient(); | ||
| } else if (StringUtils.isBlank(k8sProperties.getKubeUrl())) { | ||
| log.info("local task k8s cluster is not enabled."); | ||
| k8sJobClientSelector = new NullK8sJobClientSelector(); | ||
| } else { | ||
| // normal mode | ||
| log.info("build k8sJobClientSelector, kubeUrl={}, namespace={}", | ||
| k8sProperties.getKubeUrl(), k8sProperties.getNamespace()); | ||
| NativeK8sJobClient nativeK8sJobClient = new NativeK8sJobClient(k8sProperties); | ||
| k8sJobClientSelector = new DefaultK8sJobClientSelector(nativeK8sJobClient); | ||
| } | ||
| return k8sJobClientSelector; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters