Add Tekton-owned Step, StepTemplate, and Sidecar

This commit copies the Container struct from Kubernetes into Tekton into the existing structs Task.Step.Container, Task.Sidecar.Container, and Task.StepTemplate. This change breaks the Tekton Go libraries, but does not require any changes to the yaml that users provide. This should not change anything for users who do not use the Go libraries. The reason for this change is to have more control over our Task API. For example, we may want to modify the Container fields we support, or change fields to string types to allow them to be parameterized. This commit is the first step towards being able to make changes to parts of the Task API embedded in Container.
tektoncd · Apr 29, 2022 · 7ba591b · 7ba591b
1 parent f90ff9a
commit 7ba591b
Show file tree

Hide file tree

Showing 71 changed files with 2,762 additions and 1,822 deletions.
diff --git a/go.mod b/go.mod
@@ -35,7 +35,7 @@ require (
 	cloud.google.com/go/compute v1.5.0 // indirect
 	contrib.go.opencensus.io/exporter/ocagent v0.7.1-0.20200907061046-05415f1de66d // indirect
 	contrib.go.opencensus.io/exporter/prometheus v0.4.0 // indirect
-	github.com/Azure/azure-sdk-for-go v62.0.0+incompatible // indirect
+	github.com/Azure/azure-sdk-for-go v63.3.0+incompatible // indirect
 	github.com/Azure/go-autorest v14.2.0+incompatible // indirect
 	github.com/Azure/go-autorest/autorest v0.11.24 // indirect
 	github.com/Azure/go-autorest/autorest/adal v0.9.18 // indirect

diff --git a/go.sum b/go.sum
diff --git a/pkg/apis/pipeline/v1alpha1/cluster_task_conversion_test.go b/pkg/apis/pipeline/v1alpha1/cluster_task_conversion_test.go
@@ -58,9 +58,9 @@ func TestClusterTaskConversion(t *testing.T) {
 			},
 			Spec: TaskSpec{
 				TaskSpec: v1beta1.TaskSpec{
-					Steps: []v1beta1.Step{{Container: corev1.Container{
+					Steps: []v1beta1.Step{{
 						Image: "foo",
-					}}},
+					}},
 					Volumes: []corev1.Volume{{}},
 					Params: []v1beta1.ParamSpec{{
 						Name:        "param-1",

diff --git a/pkg/apis/pipeline/v1alpha1/condition_validation_test.go b/pkg/apis/pipeline/v1alpha1/condition_validation_test.go
@@ -24,7 +24,6 @@ import (
 	"github.com/google/go-cmp/cmp/cmpopts"
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1alpha1"
 	"github.com/tektoncd/pipeline/test/diff"
-	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"knative.dev/pkg/apis"
 )
@@ -33,10 +32,10 @@ func TestCondition_Validate(t *testing.T) {
 	c := v1alpha1.Condition{
 		ObjectMeta: metav1.ObjectMeta{Name: "condname"},
 		Spec: v1alpha1.ConditionSpec{
-			Check: v1alpha1.Step{Container: corev1.Container{
+			Check: v1alpha1.Step{
 				Name:  "cname",
 				Image: "ubuntu",
-			}},
+			},
 			Params: []v1alpha1.ParamSpec{{
 				Name: "paramname",
 				Type: v1alpha1.ParamTypeString,
@@ -67,9 +66,9 @@ func TestCondition_Invalid(t *testing.T) {
 		cond: &v1alpha1.Condition{
 			ObjectMeta: metav1.ObjectMeta{Name: "condname"},
 			Spec: v1alpha1.ConditionSpec{
-				Check: v1alpha1.Step{Container: corev1.Container{
+				Check: v1alpha1.Step{
 					Image: "",
-				}},
+				},
 			},
 		},
 		expectedError: apis.FieldError{
@@ -82,11 +81,9 @@ func TestCondition_Invalid(t *testing.T) {
 			ObjectMeta: metav1.ObjectMeta{Name: "condname"},
 			Spec: v1alpha1.ConditionSpec{
 				Check: v1alpha1.Step{
-					Container: corev1.Container{
-						Image:   "image",
-						Command: []string{"exit", "0"},
-					},
-					Script: "echo foo",
+					Image:   "image",
+					Command: []string{"exit", "0"},
+					Script:  "echo foo",
 				},
 			},
 		},
@@ -100,10 +97,8 @@ func TestCondition_Invalid(t *testing.T) {
 			ObjectMeta: metav1.ObjectMeta{Name: "condname"},
 			Spec: v1alpha1.ConditionSpec{
 				Check: v1alpha1.Step{
-					Container: corev1.Container{
-						Name:  "Cname",
-						Image: "image",
-					},
+					Name:  "Cname",
+					Image: "image",
 				},
 			},
 		},

diff --git a/pkg/apis/pipeline/v1alpha1/container_replacements.go b/pkg/apis/pipeline/v1alpha1/container_replacements.go
@@ -18,12 +18,11 @@ package v1alpha1
 
 import (
 	"github.com/tektoncd/pipeline/pkg/substitution"
-	corev1 "k8s.io/api/core/v1"
 )
 
 // ApplyContainerReplacements replaces ${...} expressions in the container's name, image, args, env, command, workingDir,
 // and volumes.
-func ApplyContainerReplacements(step *corev1.Container, stringReplacements map[string]string, arrayReplacements map[string][]string) {
+func ApplyContainerReplacements(step *Step, stringReplacements map[string]string, arrayReplacements map[string][]string) {
 	step.Name = substitution.ApplyReplacements(step.Name, stringReplacements)
 	step.Image = substitution.ApplyReplacements(step.Image, stringReplacements)
 

diff --git a/pkg/apis/pipeline/v1alpha1/container_replacements_test.go b/pkg/apis/pipeline/v1alpha1/container_replacements_test.go
@@ -34,7 +34,7 @@ func TestApplyContainerReplacements(t *testing.T) {
 		"array.replace.me": {"val1", "val2"},
 	}
 
-	s := corev1.Container{
+	s := v1alpha1.Step{
 		Name:       "$(replace.me)",
 		Image:      "$(replace.me)",
 		Command:    []string{"$(array.replace.me)"},
@@ -77,7 +77,7 @@ func TestApplyContainerReplacements(t *testing.T) {
 		}},
 	}
 
-	expected := corev1.Container{
+	expected := v1alpha1.Step{
 		Name:       "replaced!",
 		Image:      "replaced!",
 		Command:    []string{"val1", "val2"},
@@ -127,7 +127,7 @@ func TestApplyContainerReplacements(t *testing.T) {
 }
 
 func TestApplyContainerReplacements_NotDefined(t *testing.T) {
-	s := corev1.Container{
+	s := v1alpha1.Step{
 		Name: "$(params.not.defined)",
 	}
 	replacements := map[string]string{
@@ -138,7 +138,7 @@ func TestApplyContainerReplacements_NotDefined(t *testing.T) {
 		"array.replace.me": {"val1", "val2"},
 	}
 
-	expected := corev1.Container{
+	expected := v1alpha1.Step{
 		Name: "$(params.not.defined)",
 	}
 	v1alpha1.ApplyContainerReplacements(&s, replacements, arrayReplacements)

diff --git a/pkg/apis/pipeline/v1alpha1/pipeline_conversion_test.go b/pkg/apis/pipeline/v1alpha1/pipeline_conversion_test.go
@@ -25,7 +25,6 @@ import (
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1beta1"
 	resource "github.com/tektoncd/pipeline/pkg/apis/resource/v1alpha1"
 	"github.com/tektoncd/pipeline/test/diff"
-	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"knative.dev/pkg/apis"
 )
@@ -105,9 +104,9 @@ func TestPipelineConversion_Success(t *testing.T) {
 				}, {
 					Name: "task2",
 					TaskSpec: &TaskSpec{TaskSpec: v1beta1.TaskSpec{
-						Steps: []v1beta1.Step{{Container: corev1.Container{
+						Steps: []v1beta1.Step{{
 							Image: "foo",
-						}}},
+						}},
 					}},
 					RunAfter: []string{"task1"},
 				}},
@@ -162,9 +161,9 @@ func TestPipelineConversion_Failure(t *testing.T) {
 					Name: "task2",
 					TaskSpec: &TaskSpec{
 						TaskSpec: v1beta1.TaskSpec{
-							Steps: []v1beta1.Step{{Container: corev1.Container{
+							Steps: []v1beta1.Step{{
 								Image: "foo",
-							}}},
+							}},
 							Resources: &v1beta1.TaskResources{
 								Inputs: []v1beta1.TaskResource{{ResourceDeclaration: v1beta1.ResourceDeclaration{
 									Name: "input-1",

diff --git a/pkg/apis/pipeline/v1alpha1/pipeline_validation_test.go b/pkg/apis/pipeline/v1alpha1/pipeline_validation_test.go
@@ -23,7 +23,6 @@ import (
 
 	"github.com/tektoncd/pipeline/pkg/apis/pipeline/v1alpha1"
 	v1beta1 "github.com/tektoncd/pipeline/pkg/apis/pipeline/v1beta1"
-	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -157,10 +156,10 @@ func TestPipeline_Validate(t *testing.T) {
 					Name:    "foo",
 					TaskRef: &v1alpha1.TaskRef{Name: "foo-task"},
 					TaskSpec: &v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-						Steps: []v1alpha1.Step{{Container: corev1.Container{
+						Steps: []v1alpha1.Step{{
 							Name:  "foo",
 							Image: "bar",
-						}}},
+						}},
 					}},
 				}},
 			},
@@ -186,10 +185,10 @@ func TestPipeline_Validate(t *testing.T) {
 				Tasks: []v1alpha1.PipelineTask{{
 					Name: "foo",
 					TaskSpec: &v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-						Steps: []v1alpha1.Step{{Container: corev1.Container{
+						Steps: []v1alpha1.Step{{
 							Name:  "foo",
 							Image: "bar",
-						}}},
+						}},
 					}},
 				}},
 			},

diff --git a/pkg/apis/pipeline/v1alpha1/pipelinerun_conversion_test.go b/pkg/apis/pipeline/v1alpha1/pipelinerun_conversion_test.go
@@ -113,9 +113,9 @@ func TestPipelineRunConversion(t *testing.T) {
 					}, {
 						Name: "task2",
 						TaskSpec: &TaskSpec{TaskSpec: v1beta1.TaskSpec{
-							Steps: []v1beta1.Step{{Container: corev1.Container{
+							Steps: []v1beta1.Step{{
 								Image: "foo",
-							}}},
+							}},
 						}},
 						RunAfter: []string{"task1"},
 					}},

diff --git a/pkg/apis/pipeline/v1alpha1/resource_types_test.go b/pkg/apis/pipeline/v1alpha1/resource_types_test.go
@@ -24,13 +24,13 @@ import (
 )
 
 var (
-	prependStep = corev1.Container{
+	prependStep = v1alpha1.Step{
 		Name:    "prepend-step",
 		Image:   "dummy",
 		Command: []string{"doit"},
 		Args:    []string{"stuff", "things"},
 	}
-	appendStep = corev1.Container{
+	appendStep = v1alpha1.Step{
 		Name:    "append-step",
 		Image:   "dummy",
 		Command: []string{"doit"},
@@ -47,15 +47,11 @@ var (
 type TestTaskModifier struct{}
 
 func (tm *TestTaskModifier) GetStepsToPrepend() []v1alpha1.Step {
-	return []v1alpha1.Step{{
-		Container: prependStep,
-	}}
+	return []v1alpha1.Step{prependStep}
 }
 
 func (tm *TestTaskModifier) GetStepsToAppend() []v1alpha1.Step {
-	return []v1alpha1.Step{{
-		Container: appendStep,
-	}}
+	return []v1alpha1.Step{appendStep}
 }
 
 func (tm *TestTaskModifier) GetVolumes() []corev1.Volume {
@@ -84,11 +80,7 @@ func TestApplyTaskModifier(t *testing.T) {
 			}
 
 			expectedTaskSpec := v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-				Steps: []v1alpha1.Step{{
-					Container: prependStep,
-				}, {
-					Container: appendStep,
-				}},
+				Steps: []v1alpha1.Step{prependStep, appendStep},
 				Volumes: []corev1.Volume{
 					volume,
 				},
@@ -108,22 +100,22 @@ func TestApplyTaskModifier_AlreadyAdded(t *testing.T) {
 	}{{
 		name: "prepend already added",
 		ts: v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-			Steps: []v1alpha1.Step{{Container: prependStep}},
+			Steps: []v1alpha1.Step{prependStep},
 		}},
 	}, {
 		name: "append already added",
 		ts: v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-			Steps: []v1alpha1.Step{{Container: appendStep}},
+			Steps: []v1alpha1.Step{appendStep},
 		}},
 	}, {
 		name: "both steps already added",
 		ts: v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-			Steps: []v1alpha1.Step{{Container: prependStep}, {Container: appendStep}},
+			Steps: []v1alpha1.Step{prependStep, appendStep},
 		}},
 	}, {
 		name: "both steps already added reverse order",
 		ts: v1alpha1.TaskSpec{TaskSpec: v1beta1.TaskSpec{
-			Steps: []v1alpha1.Step{{Container: appendStep}, {Container: prependStep}},
+			Steps: []v1alpha1.Step{appendStep, prependStep},
 		}},
 	}, {
 		name: "volume with same name but diff content already added",

diff --git a/pkg/apis/pipeline/v1alpha1/step_replacements.go b/pkg/apis/pipeline/v1alpha1/step_replacements.go
@@ -23,5 +23,5 @@ import (
 // ApplyStepReplacements applies variable interpolation on a Step.
 func ApplyStepReplacements(step *Step, stringReplacements map[string]string, arrayReplacements map[string][]string) {
 	step.Script = substitution.ApplyReplacements(step.Script, stringReplacements)
-	ApplyContainerReplacements(&step.Container, stringReplacements, arrayReplacements)
+	ApplyContainerReplacements(step, stringReplacements, arrayReplacements)
 }