pipelinerunmetrics

Documentation

Index

• Constants
• func MetricsOnStore(logger *zap.SugaredLogger) func(name string, value interface{})
• func WithClient(ctx context.Context) context.Context
• func WithInformer(ctx context.Context) (context.Context, controller.Informer)
• type InformerKey
• type Recorder
  • func Get(ctx context.Context) *Recorder
  • func NewRecorder(ctx context.Context) (*Recorder, error)
  • func (r *Recorder) DurationAndCount(pr *v1beta1.PipelineRun) error
  • func (r *Recorder) ReportRunningPipelineRuns(ctx context.Context, lister listers.PipelineRunLister)
  • func (r *Recorder) RunningPipelineRuns(lister listers.PipelineRunLister) error
• type RecorderKey

Constants

const (
	// ReasonCancelled indicates that a PipelineRun was cancelled.
	ReasonCancelled = "Cancelled"
	// Deprecated: "PipelineRunCancelled" indicates that a PipelineRun was cancelled.
	ReasonCancelledDeprecated = "PipelineRunCancelled"
)

Functions

func MetricsOnStore

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

func WithClient

func WithClient(ctx context.Context) context.Context

func WithInformer

func WithInformer(ctx context.Context) (context.Context, controller.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 holds keys for Tekton metrics

func Get

func Get(ctx context.Context) *Recorder

Get extracts the pipelinerunmetrics.Recorder from the context.

func NewRecorder

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

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

func (*Recorder) DurationAndCount

func (r *Recorder) DurationAndCount(pr *v1beta1.PipelineRun) error

DurationAndCount logs the duration of PipelineRun execution and count for number of PipelineRuns succeed or failed returns an error if its failed to log the metrics

func (*Recorder) ReportRunningPipelineRuns

func (r *Recorder) ReportRunningPipelineRuns(ctx context.Context, lister listers.PipelineRunLister)

ReportRunningPipelineRuns invokes RunningPipelineRuns on our configured PeriodSeconds until the context is cancelled.

func (*Recorder) RunningPipelineRuns

func (r *Recorder) RunningPipelineRuns(lister listers.PipelineRunLister) error

RunningPipelineRuns logs the number of PipelineRuns 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.