0

最近、テクトンに興味があります。

Taskただし、java fabric8.tekton API を使用して実装すると、いくつかの問題が発生します。

withContainerクラス内にcontainer()単位でspec内のステップを追加しているapiが存在します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