metrics

Documentation

Index

• Variables
• func ResetRecorder()
• 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() (*Recorder, error)
  • func (r *Recorder) Count(provider, event, namespace, repository string) error
  • func (r *Recorder) CountPRDuration(namespace, repository, status, reason string, duration time.Duration) error
  • func (r *Recorder) EmitRunningPRsMetrics(prl []*tektonv1.PipelineRun) error
  • func (r *Recorder) ReportRunningPipelineRuns(ctx context.Context, lister listers.PipelineRunLister)
  • func (r *Recorder) RunningPipelineRuns(namespace, repository string, runningPRs float64) error
• type RecorderKey

Variables

var (
	Once           sync.Once
	R              *Recorder
	ErrRegistering error
)

Functions

func ResetRecorder

func ResetRecorder()

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 holds keys for metrics.

func Get

func Get(ctx context.Context) *Recorder

Get extracts the pipelinerunmetrics.Recorder from the context.

func NewRecorder

func NewRecorder() (*Recorder, error)

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

func (*Recorder) Count

func (r *Recorder) Count(provider, event, namespace, repository string) error

Count logs number of times a pipelinerun is ran for a provider.

func (*Recorder) CountPRDuration

func (r *Recorder) CountPRDuration(namespace, repository, status, reason string, duration time.Duration) error

CountPRDuration collects duration taken by a pipelinerun in seconds accumulate them in prDurationCount.

func (*Recorder) EmitRunningPRsMetrics

func (r *Recorder) EmitRunningPRsMetrics(prl []*tektonv1.PipelineRun) error

func (*Recorder) ReportRunningPipelineRuns

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

ReportRunningPipelineRuns reports running PipelineRuns on our configured ReportingPeriod until the context is cancelled.

func (*Recorder) RunningPipelineRuns

func (r *Recorder) RunningPipelineRuns(namespace, repository string, runningPRs float64) error

RunningPipelineRuns emits the number of running PipelineRuns for a repository and namespace.

type RecorderKey

type RecorderKey struct{}

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