taskrunmetrics

package
v0.0.0-...-4fc8c9b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsPartOfPipeline

func IsPartOfPipeline(tr *v1.TaskRun) (bool, string, string)

IsPartOfPipeline return true if TaskRun is a part of a Pipeline. It also return the name of Pipeline and PipelineRun

func MetricsOnStore

func MetricsOnStore(logger *zap.SugaredLogger) func(name string,
	value interface{})

MetricsOnStore returns a function that checks if metrics are configured for a config.Store, and registers it if so

func WithClient

func WithClient(ctx context.Context) context.Context

WithClient adds a metrics recorder to the given context

func WithInformer

func WithInformer(ctx context.Context) (context.Context, controller.Informer)

WithInformer returns the given context, and a configured informer

Types

type InformerKey

type InformerKey struct{}

InformerKey is used for associating the Informer inside the context.Context.

type Recorder

type Recorder struct {
	ReportingPeriod time.Duration
	// contains filtered or unexported fields
}

Recorder is used to actually record TaskRun metrics

func Get

func Get(ctx context.Context) *Recorder

Get extracts the taskrunmetrics.Recorder from the context.

func NewRecorder

func NewRecorder(ctx context.Context) (*Recorder, error)

NewRecorder creates a new metrics recorder instance to log the TaskRun related metrics

func (*Recorder) DurationAndCount

func (r *Recorder) DurationAndCount(ctx context.Context, tr *v1.TaskRun, beforeCondition *apis.Condition) error

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

func (r *Recorder) RecordPodLatency(ctx context.Context, pod *corev1.Pod, tr *v1.TaskRun) error

RecordPodLatency logs the duration required to schedule the pod for TaskRun returns an error if its failed to log the metrics

func (*Recorder) ReportRunningTaskRuns

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

func (r *Recorder) RunningTaskRuns(ctx context.Context, lister listers.TaskRunLister) error

RunningTaskRuns logs the number of TaskRuns running right now returns an error if its failed to log the metrics

type RecorderKey

type RecorderKey struct{}

RecorderKey is used for associating the Recorder inside the context.Context.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL