0

这些天我对Tekton很感兴趣。

Task但是，当我使用 java fabric8.tekton api实现时存在一些问题。

存在 api，它withContainer在类中以 container() 为单位在规范中添加步骤TaskBuilder。

但是我在符文时间收到错误消息，如下所示， 在此处输入图像描述

我可以得到一些建议吗？

Tekton 版本 - v0.10.1

我使用了如下软件包：

io.fabric8:kubernetes-client:4.7.1

io.fabric8:tekton-client:4.7.1

这是我的完整测试代码。

package com.example.tekton;

import java.util.ArrayList;
import java.util.List;
import io.fabric8.kubernetes.api.model.Container;
import io.fabric8.kubernetes.api.model.ContainerBuilder;
import io.fabric8.kubernetes.client.BaseClient;
import io.fabric8.kubernetes.client.Config;
import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.tekton.client.TektonClient;
import io.fabric8.tekton.client.DefaultTektonClient;
import io.fabric8.tekton.client.handlers.TaskHandler;
import io.fabric8.tekton.client.handlers.TaskRunHandler;
import io.fabric8.tekton.pipeline.v1alpha1.ArrayOrString;
import io.fabric8.tekton.pipeline.v1alpha1.Task;
import io.fabric8.tekton.pipeline.v1alpha1.TaskBuilder;
import io.fabric8.tekton.pipeline.v1alpha1.TaskRun;
import io.fabric8.tekton.pipeline.v1alpha1.TaskRunBuilder;
import io.fabric8.tekton.pipeline.v1alpha1.TaskRefBuilder;

public class DefaultKubernetesTest {

public Task getTask() {
  Container con = new ContainerBuilder()
                        .withNewImage("ubuntu")
                        .withNewName("echo-hello-world")
                        .addNewCommand("echo")
                        .addNewArg("hello jinwon world")
                        .build();

    Task task = new TaskBuilder()
        .withApiVersion("tekton.dev/v1alpha1")
        .withKind("Task")
        .withNewMetadata()
            .withName("echo-hello-world-test")
        .endMetadata()
        .withNewSpec()
            .addNewStep()
                .withContainer(con)
            .endStep()
        .endSpec()
        .build();

        return task;
}

public TaskRun getTaskRun() {
    TaskRun taskRun = new TaskRunBuilder()
    .withNewMetadata()
        .withName("taskrun")
        .endMetadata()
    .withNewSpec()
        .withTaskRef(new TaskRefBuilder().withName("echo-hello-world-test").withApiVersion("tekton.dev/v1alpha1").withKind("Task").build())
    .endSpec().build();
    return taskRun;
}

public static void main(String[] args) {
    ConfigBuilder config = new ConfigBuilder();
    DefaultKubernetesTest kubeTest = new DefaultKubernetesTest();
    String username = "testUser";
    String password = "testPwd";

    config = config.withMasterUrl("https://192.168.6.236:6443");
    config = config.withUsername(username);
    config = config.withPassword(password);
    Config kubeConfig = config.build();

    try (DefaultTektonClient test = new DefaultTektonClient(kubeConfig)) {
        Task task = kubeTest.getTask();
        TaskRun taskRun = kubeTest.getTaskRun();
        test.tasks().inNamespace("test").create(task);
        test.taskRuns().inNamespace("test").create(taskRun);
        test.close();
    }
}
}
4

1 回答 1

0

Tekton 附带一个准入控制器，它在允许 CRD 规范进入集群之前验证它们。由于该项目仍处于 alpha 阶段，因此进展非常快。Fabric8 可能会根据与集群上已安装的规范不同的规范来模板化 K8s 对象。您应该能够验证 Fabric8 中使用的规范版本并删除集群中的所有 Tekton 对象并在特定版本中重新应用它们。

于 2020-03-02T15:24:05.943 回答