Documentation ¶
Index ¶
- func NewController(namespace string, images pipeline.Images) func(context.Context, configmap.Watcher) *controller.Impl
- func ValidateResolvedTaskResources(params []v1alpha1.Param, rtr *resources.ResolvedTaskResources) error
- type DeletePod
- type Reconciler
- type Recorder
- func (r *Recorder) DurationAndCount(tr *v1beta1.TaskRun) error
- func (r *Recorder) RecordPodLatency(pod *corev1.Pod, tr *v1beta1.TaskRun) error
- func (r *Recorder) ReportRunningTaskRuns(ctx context.Context, lister listers.TaskRunLister)
- func (r *Recorder) RunningTaskRuns(lister listers.TaskRunLister) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewController ¶
func NewController(namespace string, images pipeline.Images) func(context.Context, configmap.Watcher) *controller.Impl
NewController instantiates a new controller.Impl from knative.dev/pkg/controller
func ValidateResolvedTaskResources ¶
func ValidateResolvedTaskResources(params []v1alpha1.Param, rtr *resources.ResolvedTaskResources) error
ValidateResolvedTaskResources validates task inputs, params and output matches taskrun
Types ¶
type Reconciler ¶
type Reconciler struct { KubeClientSet kubernetes.Interface PipelineClientSet clientset.Interface Images pipeline.Images // contains filtered or unexported fields }
Reconciler implements controller.Reconciler for Configuration resources.
func (*Reconciler) ReconcileKind ¶ added in v0.14.0
func (c *Reconciler) ReconcileKind(ctx context.Context, tr *v1beta1.TaskRun) pkgreconciler.Event
ReconcileKind compares the actual state with the desired, and attempts to converge the two. It then updates the Status block of the Task Run resource with the current status of the resource.
type Recorder ¶ added in v0.8.0
func NewRecorder ¶ added in v0.8.0
NewRecorder creates a new metrics recorder instance to log the TaskRun related metrics
func (*Recorder) DurationAndCount ¶ added in v0.8.0
DurationAndCount logs the duration of TaskRun execution and count for number of TaskRuns succeed or failed returns an error if its failed to log the metrics
func (*Recorder) RecordPodLatency ¶ added in v0.8.0
RecordPodLatency logs the duration required to schedule the pod for TaskRun returns an error if its failed to log the metrics
func (*Recorder) ReportRunningTaskRuns ¶ added in v0.14.0
func (r *Recorder) ReportRunningTaskRuns(ctx context.Context, lister listers.TaskRunLister)
ReportRunningTaskRuns invokes RunningTaskRuns on our configured PeriodSeconds until the context is cancelled.
func (*Recorder) RunningTaskRuns ¶ added in v0.8.0
func (r *Recorder) RunningTaskRuns(lister listers.TaskRunLister) error
RunningTaskRuns logs the number of TaskRuns running right now returns an error if its failed to log the metrics