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 // ReasonFailedValidation indicates that the reason for failure status is that Run failed runtime validation ReasonFailedValidation = "RunValidationFailed" // ReasonDriverError indicates that an error is throw while running the driver ReasonDriverError = "DriverError" // ReasonDriverSuccess indicates that driver finished successfully ReasonDriverSuccess = "DriverSuccess" ReasonTaskCached = "TaskCached" ExecutionID = "execution-id" ExecutorInput = "executor-input" )
for kfptaskState and driver
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 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
type TaskRunEventHandler ¶
type TaskRunEventHandler struct {
AddFunc func(obj interface{})
UpdateFunc func(oldObj, newObj interface{})
}
A RunEventHandler which only handles Add and specific Update events
func (TaskRunEventHandler) OnAdd ¶
func (r TaskRunEventHandler) OnAdd(obj interface{})
func (TaskRunEventHandler) OnDelete ¶
func (r TaskRunEventHandler) OnDelete(obj interface{})
No need to handle delete event
func (TaskRunEventHandler) OnUpdate ¶
func (r TaskRunEventHandler) OnUpdate(oldObj, newObj interface{})
OnUpdate ensures the proper handler is called depending on whether the filter matches
Source Files