pipelinelooprun

Documentation

Index

• Constants
• func EnableCustomTaskFeatureFlag(ctx context.Context) context.Context
• func Find(slice []string, val string) (int, bool)
• func NewController(namespace string) func(context.Context, configmap.Watcher) *controller.Impl
• type CacheKey
• type Reconciler
  • func (c *Reconciler) ReconcileKind(ctx context.Context, customRun *tektonv1beta1.CustomRun) pkgreconciler.Event

Constants

const (

	// LabelKeyWorkflowRunId is the label identifier a pipelinerun is managed by the Kubeflow Pipeline persistent agent.
	LabelKeyWorkflowRunId = "pipeline/runid"

	DefaultNestedStackDepth = 30
	DefaultIterationLimit   = 10000

	MaxNestedStackDepthKey = "maxNestedStackDepth"
	IterationLimitEnvKey   = "IterationLimit"
)

Functions

func EnableCustomTaskFeatureFlag

func EnableCustomTaskFeatureFlag(ctx context.Context) context.Context

func Find

func Find(slice []string, val string) (int, bool)

Find takes a slice and looks for an element in it. If found it will return it's key, otherwise it will return -1 and a bool of false.

func NewController

func NewController(namespace string) func(context.Context, configmap.Watcher) *controller.Impl

NewController instantiates a new controller.Impl from knative.dev/pkg/controller

Types

type CacheKey

type CacheKey struct {
	Params           []tektonv1.Param                       `json:"params"`
	PipelineLoopSpec *pipelineloopv1alpha1.PipelineLoopSpec `json:"pipelineSpec"`
}

type Reconciler

type Reconciler struct {
	KubeClientSet kubernetes.Interface
	// contains filtered or unexported fields
}

Reconciler implements controller.Reconciler for Configuration resources.

func (*Reconciler) ReconcileKind

func (c *Reconciler) ReconcileKind(ctx context.Context, customRun *tektonv1beta1.CustomRun) pkgreconciler.Event

ReconcileKind compares the actual state with the desired, and attempts to converge the two. It then updates the Status block of the CustomRun resource with the current status of the resource.