Documentation ¶
Overview ¶
// Copyright 2023 kubeflow.org // // 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 // // https://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.
Index ¶
Constants ¶
const ( StateInit = iota StateRunning StateDone )
for exitHandlerState
const LabelKeyWorkflowRunId = "pipeline/runid"
borrow from kubeflow/pipeline/backend/src/common/util
Variables ¶
This section is empty.
Functions ¶
func NewController ¶
TODO: add caching and logging support NewController instantiates a new controller.Impl from knative.dev/pkg/controller
Types ¶
type PipelineRunEventHandler ¶
type PipelineRunEventHandler struct { AddFunc func(obj interface{}) UpdateFunc func(oldObj, newObj interface{}) }
A RunEventHandler which only handles Add and specific Update events
func (PipelineRunEventHandler) OnAdd ¶
func (r PipelineRunEventHandler) OnAdd(obj interface{})
func (PipelineRunEventHandler) OnDelete ¶
func (r PipelineRunEventHandler) OnDelete(obj interface{})
No need to handle delete event
func (PipelineRunEventHandler) OnUpdate ¶
func (r PipelineRunEventHandler) OnUpdate(oldObj, newObj interface{})
OnUpdate ensures the proper handler is called depending on whether the filter matches
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
Reconciler implements controller.Reconciler for Configuration resources.
func (*Reconciler) FinalizeKind ¶
func (r *Reconciler) FinalizeKind(ctx context.Context, run *tektonv1beta1.CustomRun) reconciler.Event
func (*Reconciler) ReconcileKind ¶
func (r *Reconciler) ReconcileKind(ctx context.Context, run *tektonv1beta1.CustomRun) reconciler.Event
type RunEventHandler ¶
type RunEventHandler struct { AddFunc func(obj interface{}) UpdateFunc func(oldObj, newObj interface{}) }
A RunEventHandler which only handles Add and specific Update events
func (RunEventHandler) OnAdd ¶
func (r RunEventHandler) OnAdd(obj interface{})
func (RunEventHandler) OnDelete ¶
func (r RunEventHandler) OnDelete(obj interface{})
No need to handle delete event
func (RunEventHandler) OnUpdate ¶
func (r RunEventHandler) OnUpdate(oldObj, newObj interface{})
OnUpdate ensures the proper handler is called depending on whether the filter matches